Python pymysql

pip  install  PyMysql

數據庫鏈接

#!/usr/bin/python3    import  pymysql    # 打開數據庫鏈接 # mysql地址localhost，用戶名testuser，密碼test123，庫名TESTDB。 # 庫名非必須 db  =  pymysql.connect( "localhost" , "testuser" , "test123" , "TESTDB"  )    # 使用 cursor() 方法建立一個遊標對象 cursor cursor  =  db.cursor()    # 使用 execute()  方法執行 SQL 查詢 cursor.execute( "SELECT VERSION()" )    # 使用 fetchone() 方法獲取單條數據. data  =  cursor.fetchone()    print  ( "Database version : %s "  %  data)    # 關閉數據庫鏈接 db.close()

建立數據庫表

#!/usr/bin/python3    import  pymysql    # 打開數據庫鏈接 db  =  pymysql.connect( "localhost" , "testuser" , "test123" , "TESTDB"  )    # 使用 cursor() 方法建立一個遊標對象 cursor cursor  =  db.cursor()    # 使用 execute() 方法執行 SQL，若是表存在則刪除 cursor.execute( "DROP TABLE IF EXISTS EMPLOYEE" )    # 使用預處理語句建立表 sql  =  """CREATE TABLE EMPLOYEE (           FIRST_NAME  CHAR(20) NOT NULL,           LAST_NAME  CHAR(20),           AGE INT,            SEX CHAR(1),           INCOME FLOAT )"""    cursor.execute(sql)    # 關閉數據庫鏈接 db.close()

數據插入

 

#!/usr/bin/python3    import  pymysql    # 打開數據庫鏈接 db  =  pymysql.connect( "localhost" , "testuser" , "test123" , "TESTDB"  )    # 使用cursor()方法獲取操做遊標 cursor  =  db.cursor()    # SQL 插入語句 sql  =  "INSERT INTO EMPLOYEE(FIRST_NAME, \         LAST_NAME, AGE, SEX, INCOME) \         VALUES ( '%s' ,  '%s' ,  '%d' ,  '%c' ,  '%d'  )"  %  \         ( 'Mac' ,  'Mohan' ,  20 ,  'M' ,  2000 ) try :     # 執行sql語句     cursor.execute(sql)     # 執行sql語句     db.commit() except :     # 發生錯誤時回滾     db.rollback()    # 關閉數據庫鏈接 db.close()

數據庫查詢操做

Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

• fetchone(): 該方法獲取下一個查詢結果集。結果集是一個對象
• fetchall(): 接收所有的返回結果行.
• rowcount: 這是一個只讀屬性，並返回執行execute()方法後影響的行數。

查詢EMPLOYEE表中salary（工資）字段大於1000的全部數據：

#!/usr/bin/python3    import  pymysql    # 打開數據庫鏈接 db  =  pymysql.connect( "localhost" , "testuser" , "test123" , "TESTDB"  )    # 使用cursor()方法獲取操做遊標 cursor  =  db.cursor()    # SQL 查詢語句 sql  =  "SELECT  *  FROM EMPLOYEE \         WHERE INCOME >  '%d' "  %  ( 1000 ) try :     # 執行SQL語句     cursor.execute(sql)     # 獲取全部記錄列表     results  =  cursor.fetchall()     for  row  in  results:        fname  =  row[ 0 ]        lname  =  row[ 1 ]        age  =  row[ 2 ]        sex  =  row[ 3 ]        income  =  row[ 4 ]         # 打印結果        print  ( "fname=%s,lname=%s,age=%d,sex=%s,income=%d"  %  \               (fname, lname, age, sex, income )) except :     print  ( "Error: unable to fetch data" )    # 關閉數據庫鏈接 db.close()