python - 數據庫操作(mysqlclient) - 簡單demo

數據庫如下：

 

 

直接上代碼，如下：

import MySQLdb   # 導入數據庫包

conn = MySQLdb.connect(
    host='fhdskhaf.aliyuncs.com',   # 連接服務器
    port=3306,  # 端口號，默認3306的話可以省略這一行
    user='zhangsan', # 用戶名
    passwd='fhdkasjf',  # 密碼
    db='datav', # 數據庫名    ----- 1.此處也可以不指定數據庫名，在sql語句中寫庫名，可以使用多個不同的庫  2. 也可以此處指定數據庫A，sql中用到數據庫B
    charset='utf8'  # 編碼方式（字符集）
)

c = conn.cursor()  # 創建游標

# 查詢每一行
c.execute('select * from zy_1')
for i in range(c.rowcount):
    row = c.fetchone()
    print(row)
    if row[1] == 'shuxue':    # row[1]取出每行數據中的某一列，下標從0開始
        print('ok')
        break

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

增刪改查，分別如下（增刪改需要使用commit()）：

# 增
c.execute("insert into zy_1(name, score) VALUES('yuwen', 99), ('shuxue', 89)")
conn.commit()  # conn有commit方法，cur沒有

# 刪
c.execute("delete from zy_1 where id > 2")
conn.commit()

# 改
c.execute("update zy_1 set score = 66 where id = 1")
conn.commit()

# 查
c.execute('select * from zy_1')
rows = c.fetchall()
print(rows)

三種查詢方法：

c.fetchone()    # 查詢一行
c.fetchmany(2)  # 查詢2行
c.fetchall()    # 全部查詢出來

 

 

ps:

單行sql

sql = "select version()"

多行sql

sql = "select " \
      "version()"

 

 

 

 

完善一些的寫法（加上異常處理）：

sql1 = "select * from tb_3"
try:
    cur.execute(sql1)
    conn.commit()
except:
    conn.rollback()  # 發生錯誤時回滾