当前位置: 首页 > 后端技术 > Python

pymysql操作数据库

时间:2023-03-25 19:35:18 Python

importpymysql.cursors#连接数据库connection=pymysql.connect(host='localhost',user='user',password='passwd',database='db',cursorclass=pymysql.cursors.DictCursor)withconnection:withconnection.cursor()ascursor:#创建一条新记录sql="INSERTINTO`users`(`email`,`password`)VALUES(%s,%s)"cursor.execute(sql,('webmaster@python.org','very-secret'))#默认情况下连接不是自动提交的。所以你必须承诺保存#你的更改。connection.commit()withconnection.cursor()ascursor:#读取单条记录sql="SELECT`id`,`password`FROM`users`WHERE`email`=%s"cursor.execute(sql,('webmaster@python.org',))result=cursor.fetchone()print(result)frompymysqlimportconnect#创建连接连接conn=connect(host='localhost',port=3306,database='df',user='root',password='mysql',charset='utf8')#获取Cursor对象curson=conn.cursor()count=curson.execute('select*fromgoods;');print('查询%d条数据'%count)print(curson.fetchone())#打印一条print(curson.fetchmany())#元祖中面包的元祖,只是一条数据print(curson.fetchmany(3))#传参数,传几取几print(curson.fetchall())#全部取line_count=curson.fetchone()print(line_count)print(line_count[0])print(line_count[1])print(line_count[2])#可以一条一条的取出一条语句的内容#关闭Cursor对象curson.close()#关闭Connection对象conn.close()