python下操作mysql 之 pymsql

　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　pymsql是Python中操作MySQL的模塊，

下載安裝:

pip3 install pymysql

使用操作
　　1, 執行SQL

#!/usr/bin/env python

# -*- coding:utf-8 -*-

import pymysql

  

# 創建連接

conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1
 
‘)

# 創建遊標

cursor = conn.cursor()

  

# 執行SQL，並返回收影響行數

effect_row = cursor.execute("update hosts set host = ‘1.1.1.2‘")

  

# 執行SQL，並返回受影響行數

#effect_row = cursor.execute("update hosts set host = ‘1.1.1.2‘ where nid > %s", (1,))

  

# 執行SQL，並返回受影響行數

#effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])
 


  

  

# 提交，不然無法保存新建或者修改的數據

conn.commit()

  

# 關閉遊標

cursor.close()

# 關閉連接

conn.close()

　　2, 獲取新創建數據自增ID

#!/usr/bin/env python

# -*- coding:utf-8 -*-

import pymysql

  

conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘
 
t1‘)

cursor = conn.cursor()

cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])

conn.commit()

cursor.close()

conn.close()

  

# 獲取最新自增ID

new_id = cursor.lastrowid

　　3, 獲取查詢數據

#!/usr/bin/env python

# -*- coding:utf-8 -*-

import pymysql

  

conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘)

cursor = conn.cursor()

cursor.execute("select * from hosts")

  

# 獲取第一行數據

row_1 = cursor.fetchone()

  

# 獲取前n行數據

# row_2 = cursor.fetchmany(3)

# 獲取所有數據

# row_3 = cursor.fetchall()

  

conn.commit()

cursor.close()

conn.close()

　　註：在fetch數據時按照順序進行，可以使用cursor.scroll(num,mode)來移動遊標位置，如：

• cursor.scroll(1,mode=‘relative‘) # 相對當前位置移動
• cursor.scroll(2,mode=‘absolute‘) # 相對絕對位置移動

　　4, fetch 數據類型

#!/usr/bin/env python

# -*- coding:utf-8 -*-

import pymysql

  

conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘)

  

# 遊標設置為字典類型

cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

r = cursor.execute("call p1()")

  

result = cursor.fetchone()

  

conn.commit()

cursor.close()

conn.close()

　　5,input 下執行

import pymysql
username = input(‘請輸入用戶名：‘)

pwd = input(‘請輸入密碼：‘)



# 1.連接
conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘‘, db=‘db8‘, charset=‘utf8‘)


# 2.創建遊標
cursor = conn.cursor()


# 操作
# 增
# sql = "insert into userinfo(username,pwd) values (%s,%s)"


# effect_row = cursor.execute(sql,(username,pwd))
#同時插入多條數據
#cursor.executemany(sql,[(‘李四‘，‘110‘),（‘王五‘，‘119‘）]) 

# print(effect_row)#

# 改
# sql = "update userinfo set username = %s  where id = 2"
# effect_row = cursor.execute(sql,username)
# print(effect_row)


# 刪
sql = "delete from userinfo  where id = 2"
effect_row = cursor.execute(sql)
print(effect_row)


#一定記得commit
conn.commit()

# 4.關閉遊標
cursor.close()

# 5.關閉連接
conn.close()

python下操作mysql 之 pymsql