首页 > 数据库技术 > 详细

操作mysql

时间:2019-10-27 19:53:11      阅读:87      评论:0      收藏:0      [点我收藏+]
#建连接
#设游标
#执行sql语句
import pymysql
ip ="1.1.1.1"
user = ‘admin‘
password="123456" #需是字符串
db=‘student‘
port=3306
charset = ‘utf8‘ #注意是utf8,而不是utf-8
conn = pymysql.connect(host=ip , port=port,
user=user, password=password,
db=db, charset=charset
) #建立连接,port可以不写,默认是3306
cur= conn.cursor(pymysql.cursors.DictCursor)#游标
sql = ‘select *from user limit 10;‘
cur.execute(sql) #执行sql语句,不返回结果
#conn.commit() #提交;执行insert、update的时候要commit一下;如果不写的话,conn中加一个参数autocommit=True,自动提交
one = cur.fetchone()  #获取一条数据,若执行fetchall后,其他数据都取不到了,类似于文件指针
many = cur.fetchmany() #获取多条数据,输入几就是取几条
all = cur.fetchall() #获取所有数据,数据量比较小的时候使用,数据量大的话 还是fetchone
cur.close()#关游标
conn.close()#关连接
print(one) #cur加上pymysql.cursors.DictCursor,这个取出来是一个字典
print(many) #cur加上pymysql.cursors.DictCursor,这个取出来是一个list,里面值是字典
print(all) #cur加上pymysql.cursors.DictCursor,这个取出来是一个list,里面值是字典

##封装成函数
def op_mysql(sql):
db_info = {‘user‘: ‘jxz‘, ‘password‘: ‘123456‘,
‘host‘: ‘1.1.1.1‘, ‘db‘: ‘stu‘, ‘port‘: 3306, ‘charset‘: ‘utf8‘,
‘autocommit‘: True}
conn = pymysql.connect(**db_info) # 建立连接
cur = conn.cursor(pymysql.cursors.DictCursor) # 游标
cur.execute(sql) # 执行sql语句,insert 、update 、delete
result = cur.fetchall()
cur.close()
conn.close()
return result



操作mysql

原文:https://www.cnblogs.com/lsl1230/p/11748512.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!