日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
PostgreSQL連接Python

安裝

PostgreSQL可以用Python psycopg2模塊集成。 sycopg2是Python編程語(yǔ)言的PostgreSQL數(shù)據(jù)庫(kù)的適配器。 其程序代碼少,速度快,穩(wěn)定。不需要單獨(dú)安裝這個(gè)模塊,因?yàn)樗J(rèn)情況下被運(yùn)往隨著Python版本在2.5.x一起的。如果不把它安裝在機(jī)器上,然后可 以使用yum命令安裝它,如下所示:

 
 
 
 
  1. $yum install python-psycopg2 

要使用psycopg2的模塊,首先必須創(chuàng)建一個(gè)Connection對(duì)象,它表示數(shù)據(jù)庫(kù)然后再可以選擇創(chuàng)建游標(biāo)對(duì)象,這將幫助執(zhí)行的所有SQL語(yǔ)句。

Python psycopg2 模塊APIs

以下是psycopg2的重要的的模塊例程可以滿足Python程序與PostgreSQL數(shù)據(jù)庫(kù)的工作。如果尋找一個(gè)更復(fù)雜的應(yīng)用程序,那么可以看看Python psycopg2的模塊的官方文檔。

 連接到數(shù)據(jù)庫(kù)

Python代碼顯示了如何連接到一個(gè)現(xiàn)有的數(shù)據(jù)庫(kù)。如果數(shù)據(jù)庫(kù)不存在,那么它就會(huì)被創(chuàng)建,最終將返回一個(gè)數(shù)據(jù)庫(kù)對(duì)象。

 
 
 
 
  1. #!/usr/bin/python 
  2.  
  3. import psycopg2 
  4.  
  5. conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432") 
  6.  
  7. print "Opened database successfully" 

在這里,也可以提供數(shù)據(jù)庫(kù)testdb的名稱,如果數(shù)據(jù)庫(kù)成功打開(kāi),那么它會(huì)給下面的消息:

 
 
 
 
  1. Open database successfully 

創(chuàng)建表

以下Python程序?qū)⑹褂靡郧皠?chuàng)建的數(shù)據(jù)庫(kù)中創(chuàng)建一個(gè)表:

 
 
 
 
  1. #!/usr/bin/python 
  2.  
  3. import psycopg2 
  4.  
  5. conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432") 
  6. print "Opened database successfully" 
  7.  
  8. cur = conn.cursor() 
  9. cur.execute('''CREATE TABLE COMPANY 
  10.        (ID INT PRIMARY KEY     NOT NULL, 
  11.        NAME           TEXT    NOT NULL, 
  12.        AGE            INT     NOT NULL, 
  13.        ADDRESS        CHAR(50), 
  14.        SALARY         REAL);''') 
  15. print "Table created successfully" 
  16.  
  17. conn.commit() 
  18. conn.close() 

 上述程序執(zhí)行時(shí),它會(huì)創(chuàng)建表COMPANY 在數(shù)據(jù)庫(kù)test.db中,它會(huì)顯示以下消息:

 
 
 
 
  1. Opened database successfully 
  2. Table created successfully 

 #p#

INSERT 操作

Python程序顯示了我們?nèi)绾蝿?chuàng)建表COMPANY 在上面的例子中創(chuàng)建表中的記錄:

 
 
 
 
  1. #!/usr/bin/python 
  2.  
  3. import psycopg2 
  4.  
  5. conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432") 
  6. print "Opened database successfully" 
  7.  
  8. cur = conn.cursor() 
  9.  
  10. cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \ 
  11.       VALUES (1, 'Paul', 32, 'California', 20000.00 )"); 
  12.  
  13. cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \ 
  14.       VALUES (2, 'Allen', 25, 'Texas', 15000.00 )"); 
  15.  
  16. cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \ 
  17.       VALUES (3, 'Teddy', 23, 'Norway', 20000.00 )"); 
  18.  
  19. cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \ 
  20.       VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 )"); 
  21.  
  22. conn.commit() 
  23. print "Records created successfully"; 
  24. conn.close() 

上述程序執(zhí)行時(shí),它會(huì)創(chuàng)建COMPANY表中的記錄,并顯示以下兩行:

 
 
 
 
  1. Opened database successfully 
  2. Records created successfully 

 SELECT 操作

Python程序,顯示如何獲取并顯示COMPANY 表在上面的例子中創(chuàng)建的記錄:

 
 
 
 
  1. #!/usr/bin/python 
  2.  
  3. import psycopg2 
  4.  
  5. conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432") 
  6. print "Opened database successfully" 
  7.  
  8. cur = conn.cursor() 
  9.  
  10. cur.execute("SELECT id, name, address, salary  from COMPANY") 
  11. rows = cur.fetchall() 
  12. for row in rows: 
  13.    print "ID = ", row[0] 
  14.    print "NAME = ", row[1] 
  15.    print "ADDRESS = ", row[2] 
  16.    print "SALARY = ", row[3], "\n" 
  17.  
  18. print "Operation done successfully"; 
  19. conn.close() 

 當(dāng)上述程序執(zhí)行時(shí),它會(huì)產(chǎn)生以下結(jié)果:

 
 
 
 
  1. Opened database successfully 
  2. ID =  1 
  3. NAME =  Paul 
  4. ADDRESS =  California 
  5. SALARY =  20000.0 
  6.  
  7. ID =  2 
  8. NAME =  Allen 
  9. ADDRESS =  Texas 
  10. SALARY =  15000.0 
  11.  
  12. ID =  3 
  13. NAME =  Teddy 
  14. ADDRESS =  Norway 
  15. SALARY =  20000.0 
  16.  
  17. ID =  4 
  18. NAME =  Mark 
  19. ADDRESS =  Rich-Mond 
  20. SALARY =  65000.0 
  21.  
  22. Operation done successfully 

UPDATE 操作

Python代碼顯示如何,我們可以使用UPDATE語(yǔ)句來(lái)更新記錄,然后從COMPANY表獲取并顯示更新的記錄:

 
 
 
 
  1. #!/usr/bin/python 
  2.  
  3. import psycopg2 
  4.  
  5. conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432") 
  6. print "Opened database successfully" 
  7.  
  8. cur = conn.cursor() 
  9.  
  10. cur.execute("UPDATE COMPANY set SALARY = 25000.00 where ID=1") 
  11. conn.commit 
  12. print "Total number of rows updated :", cur.rowcount 
  13.  
  14. cur.execute("SELECT id, name, address, salary  from COMPANY") 
  15. rows = cur.fetchall() 
  16. for row in rows: 
  17.    print "ID = ", row[0] 
  18.    print "NAME = ", row[1] 
  19.    print "ADDRESS = ", row[2] 
  20.    print "SALARY = ", row[3], "\n" 
  21.  
  22. print "Operation done successfully"; 
  23. conn.close() 

 當(dāng)上述程序執(zhí)行時(shí),它會(huì)產(chǎn)生以下結(jié)果:

 
 
 
 
  1. Opened database successfully 
  2. Total number of rows updated : 1 
  3. ID =  1 
  4. NAME =  Paul 
  5. ADDRESS =  California 
  6. SALARY =  25000.0 
  7.  
  8. ID =  2 
  9. NAME =  Allen 
  10. ADDRESS =  Texas 
  11. SALARY =  15000.0 
  12.  
  13. ID =  3 
  14. NAME =  Teddy 
  15. ADDRESS =  Norway 
  16. SALARY =  20000.0 
  17.  
  18. ID =  4 
  19. NAME =  Mark 
  20. ADDRESS =  Rich-Mond 
  21. SALARY =  65000.0 
  22.  
  23. Operation done successfully 

#p#

DELETE 操作

Python代碼顯示了如何我們可以使用DELETE語(yǔ)句刪除記錄,然后獲取并顯示COMPANY 表剩余的記錄:

 
 
 
 
  1. #!/usr/bin/python 
  2.  
  3. import psycopg2 
  4.  
  5. conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432") 
  6. print "Opened database successfully" 
  7.  
  8. cur = conn.cursor() 
  9.  
  10. cur.execute("DELETE from COMPANY where ID=2;") 
  11. conn.commit 
  12. print "Total number of rows deleted :", cur.rowcount 
  13.  
  14. cur.execute("SELECT id, name, address, salary  from COMPANY") 
  15. rows = cur.fetchall() 
  16. for row in rows: 
  17.    print "ID = ", row[0] 
  18.    print "NAME = ", row[1] 
  19.    print "ADDRESS = ", row[2] 
  20.    print "SALARY = ", row[3], "\n" 
  21.  
  22. print "Operation done successfully"; 
  23. conn.close() 

 當(dāng)上述程序執(zhí)行時(shí),它會(huì)產(chǎn)生以下結(jié)果:

 
 
 
 
  1. Opened database successfully 
  2. Total number of rows deleted : 1 
  3. ID =  1 
  4. NAME =  Paul 
  5. ADDRESS =  California 
  6. SALARY =  20000.0 
  7.  
  8. ID =  3 
  9. NAME =  Teddy 
  10. ADDRESS =  Norway 
  11. SALARY =  20000.0 
  12.  
  13. ID =  4 
  14. NAME =  Mark 
  15. ADDRESS =  Rich-Mond 
  16. SALARY =  65000.0 
  17.  
  18. Operation done successfully 

原文鏈接:http://www.yiibai.com/html/postgresql/2013/080998.html


網(wǎng)站名稱:PostgreSQL連接Python
瀏覽路徑:http://www.5511xx.com/article/copojie.html