user表结构
#coding = utf-8
'''
如果mysql模块导入不进去,请执行以下命令
python -m pip install mysql-connector
'''
import mysql.connector
#创建连接
mydb = mysql.connector.connect(
host="localhost", # 数据库主机地址
user="root", # 数据库用户名
passwd="mysql", # 数据库密码
database="queue" # 数据库源名称
)
mycursor = mydb.cursor()
def findAll():
print("查看所有数据")
#执行SQL 不带参数的查询语句
mycursor.execute("select * from user")
#获取所有记录
myresult = mycursor.fetchall()
for oneData in myresult:
print(oneData)
print("")
def inputAA():
input("任意键继续")
print("************不带参数的查询语句*********************")
#执行SQL 不带参数的查询语句
mycursor.execute("select * from user")
#获取所有记录
myresult = mycursor.fetchall()
for oneData in myresult:
print(oneData)
inputAA()
print("\n************带参数的查询语句*********************")
#执行SQL 不带参数的查询语句
selectSql = "select * from user where account= %s"
#元组只有一个元素的时候,要加个,来标明其是元组而不是运算符
params1 = ("aaaa3333",)
mycursor.execute(selectSql, params1)
#获取所有记录
myresult = mycursor.fetchall()
for oneData in myresult:
print(oneData)
inputAA()
print("\n************带参数的插入语句**********************")
insertSql = "insert into user(account,name) values(%s, %s)"
params2 = ("111222", "小王子")
mycursor.execute(insertSql, params2)
#涉及到修改,插入,删除的时候需要commit一下
mydb.commit()
#获取操作成功的数据数量
print(mycursor.rowcount, "记录插入成功。")
findAll()
inputAA()
print("\n************带参数的更新语句**********************")
updateSql = "update user set name=%s where account=%s"
params3 = ("小王子1111","111222")
mycursor.execute(updateSql, params3)
#涉及到修改,插入,删除的时候需要commit一下
mydb.commit()
#获取操作成功的数据数量
print(mycursor.rowcount, "记录更新成功。")
findAll()
inputAA()
print("\n************带参数的删除语句**********************")
deleteSql = "delete from user where account = %s"
params4 = ("111222",)
mycursor.execute(deleteSql, params4)
#涉及到修改,插入,删除的时候需要commit一下
mydb.commit()
#获取操作成功的数据数量
print(mycursor.rowcount, "记录删除成功。")
findAll()
inputAA()
print("\n************带参数的批量插入语句**********************")
insertBatchSql = "insert into user(account,name) values(%s, %s)"
params5 = [("111111", "小王子"),("222222", "小王子"),("333333", "小王子")]
mycursor.executemany(insertBatchSql, params5)
#涉及到修改,插入,删除的时候需要commit一下
mydb.commit()
#获取操作成功的数据数量
print(mycursor.rowcount, "记录添加成功。")
findAll()
inputAA()
print("\n************带参数的批量删除语句**********************")
deleteBatchSql = "delete from user where account = %s"
params6 = [("111111",),("222222",),("333333",)]
mycursor.executemany(deleteBatchSql, params6)
#涉及到修改,插入,删除的时候需要commit一下
mydb.commit()
#获取操作成功的数据数量
print(mycursor.rowcount, "记录删除成功。")
findAll()
inputAA()