python使用pymsql

pymsql是Python中操作MySQL的模塊，其使用方法和MySQLdb幾乎相同。

1、執行SQL

#!/usr/bin/env python

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

import pymysql

# 創建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='jiangjj')

# 創建游標

cursor = conn.cursor()

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

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

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

conn.commit()

# 關閉游標

cursor.close()

# 關閉連接

conn.close()

2、獲取新創建的數據

import pymysql

# 創建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='jiangjj')

# 創建游標

cursor = conn.cursor()

#參數傳遞，必須使用參數的形式

# inp=input("請輸入班級：")

# r = cursor.execute('insert into calss(caption) values(%s)',inp)

# print(r)

#方式1

sid=input("請輸入ID:")

gender=input('請輸入性別：')

class_cid=input("請輸入班級id：")

sname=input("請輸入姓名：")

r = cursor.execute('insert into student(sid,gender,class_cid,sname) values(%s,%s,%s,%s)',(sid,gender,class_cid,sname))

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

conn.commit()

# 關閉游標

cursor.close()

# 關閉連接

補充：采用元組或列表添加數據

l = [

(18,'男',2,'測試1'),

(19,'男',2,'測試2'),

(20,'男',2,'測試3')

]

r = cursor.executemany('insert into student(sid,gender,class_cid,sname) values(%s,%s,%s,%s)',l)

print(r)

#更新數據

cursor.execute('update student set sname=%s where sid=%s',('將將將',1))

#刪除數據

cursor.execute('delete from student where sid=%s',(20))

3、獲取查詢數據

#查詢數據

r = cursor.execute('select * from student')

print(r)

# result = cursor.fetchall()        #獲取所有數據

# print(result)

# result = cursor.fetchone()        #根據指針，獲取第一行數據

# print(result)

result = cursor.fetchmany(3)      #獲取前n行數據

print(result)

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

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

• cursor.scroll(2,mode='absolute') # 相對絕對位置移動

4、獲取新創建數據自增

import pymysql

# 創建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='authority')

# 創建游標,將游標設置為字典類型

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

#sql

user = input("請輸入用戶名：")

password = input('請輸入用戶密碼：')

cursor.execute('select nid,username from user where username=%s and password=%s',(user,password))

reslut = cursor.fetchall()

print(reslut)

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

conn.commit()

#獲取新創建數據自增ID

nid = cursor.lastrowid

print(nid)

# 關閉游標

cursor.close()

# 關閉連接

conn.close()