python連接postgres方法


Python使用PyGreSQL操作PostgreSQL:

import pg

def operate_postgre_tbl_product():
    try:
 #db = pg.connect(dbname = 'postgres', host = '192.168.1.200', user = 'postgres', passwd = 'postgres') 方法一
 db = pg.connect("host=192.168.1.200 port=5432 dbname=postgres user=postgres") 方法二

    except Exception as  e:
         print (e.args[0])
         return


    sql_desc = "select * from zhang;"
    for row in db.query(sql_desc).dictresult():
        print (row)


    db.close()


if __name__ == '__main__':
    operate_postgre_tbl_product()

PostgreSQL可以使用psycopg2模塊與Python集成。sycopg2是用於Python編程語言的PostgreSQL數據庫適配器。 psycopg2是非常小,快速,穩定的。

## 導入psycopg2包
import psycopg2
## 連接到一個給定的數據庫
conn = psycopg2.connect(database="postgres", user="postgres",password="postgres", host="192.168.1.200", port="5432")
## 建立游標,用來執行數據庫操作
cursor = conn.cursor()

## 執行SQL命令
cursor.execute("CREATE TABLE test_conn(id int, name text)")
cursor.execute("INSERT INTO test_conn values(1,'haha')")

## 提交SQL命令
conn.commit()

## 執行SQL SELECT命令
cursor.execute("select * from test_conn")

## 獲取SELECT返回的元組
rows = cursor.fetchall()
for row in rows:
    print('id = ',row[0], 'name = ', row[1], '\n')

## 關閉游標
cursor.close()

## 關閉數據庫連接
conn.close()

十年飲冰,難涼熱血。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM