Pymysql知識

查詢操做

# 查詢操做：
# fetchone()#返回一個
# fetchall()#返回所有
# fetchmany()#返回多個

import pymysql

db=pymysql.connect('127.0.0.1','root','','db4')#鏈接數據庫

cursor=db.cursor()#建立遊標對象  要是以字典的形式展開
#pymysql.cursors.DictCursor以字典的形式顯示
sql='select * from employee'

cursor.execute(sql)

# ret=cursor.fetchall()#所有拿到數據，以元組的形式
# print(ret)

# ret=cursor.fetchone()#每次拿一個
# print(ret)
#
# ret=cursor.fetchone()
# print(ret)
#
ret=cursor.fetchone()
print(type(ret))

# ret=cursor.fetchmany(3)#以元組的形式返回
# print(ret)

cursor.close()#關閉遊標

db.close()#關閉數據庫鏈接

插入操做

import pymysql

conn=pymysql.connect('127.0.0.1','root','','db7')#鏈接數據庫

cursor=conn.cursor()#建立遊標

sql="insert into t1  (name)values('alex'),('wusir')"#字段名要+括號
try:
    cursor.execute(sql)
    conn.commit()#提交到數據庫

except:
    print(1)
    conn.rollback()#若是發生錯誤就回滾

conn.close()

修改操做

import pymysql
conn=pymysql.connect('127.0.0.1','root','','db7')#數據庫鏈接

cursor=conn.cursor()#遊標

sql="update t1 set name='alexsb' where id=1"

try:
    cursor.execute(sql)
    conn.commit()
except:
    print(1)
    conn.rollback()

conn.close()

刪除操做

import pymysql

db=pymysql.connect('127.0.0.1','root','','db7')#鏈接數據庫

cursor=db.cursor()#建立遊標對象

sql="delete from t1 where id=1"

try:
    cursor.execute(sql)#執行sql語句
    db.commit()#提交修改
except:
    print(1)
    db.rollback()#出錯數據回滾

db.close()