python怎么操作pymysql数据库

本篇内容主要讲解"python怎么操作pymysql数据库"，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习"python怎么操作pymysql数据库"吧!

一、安装

pip install pymysql

二、连接数据库

• 三种连接数据库的方式

import pymysql# 方式一conn = pymysql.connect('localhost', 'root', 'root')# 方式二conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='', charset='utf8')# 方式三config = {'host': '127.0.0.1','port': 3306,'user': 'root','passwd': 'root','charset': 'utf8'}conn = pymysql.connect(**config)

三、创建数据库

• 创建一个test数据库并进入

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")# 使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor()cursor.execute('DROP DATABASE IF EXISTS test')cursor.execute('CREATE DATABASE IF NOT EXISTS test')conn.select_db('test')

四、创建数据表

• 创建一张user表

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()cursor.execute('CREATE TABLE user(id int primary key,name varchar(30))')

五、插入一条数据

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()try:# 执行SQL语句sql = 'INSERT INTO user values("%d","%s")' %(1,"autofelix")cursor.execute(sql)# 提交到数据库执行db.commit()except:# 发生错误时回滚db.rollback()finally:# 关闭游标连接cursor.close()# 关闭数据库连接conn.close()

六、插入多条数据

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()try:# 执行SQL语句values = [(1, 'autofelix'), (2, '飞兔小哥')]cursor.executemany('INSERT INTO user values(%s,%s)', values)# 提交到数据库执行db.commit()except:# 发生错误时回滚db.rollback()finally:# 关闭游标连接cursor.close()# 关闭数据库连接conn.close()

七、数据统计

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()count = cursor.execute('SELECT * FROM user')# 统计数据总数print('total records: %d' %count)# 统计字段数print('total records:', cursor.rowcount)

八、获取表名信息

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()desc = cursor.descriptionprint("%s %3s" % (desc[0][0], desc[1][0]))

九、获取单条数据

• 使用 fetchone 方法获取单条数据

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()# 使用 execute() 方法执行 SQL 查询cursor.execute("SELECT VERSION()")# 使用 fetchone() 方法获取单条数据.data = cursor.fetchone()print("Database version : %s " % data)# 关闭数据库连接db.close()

十、查询多条数据

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()cursor.execute('SELECT * FROM user')results = cursor.fetchmany(5)for r in results:print (r)

十一、查询所有数据

import pymysqldb = pymysql.connect("localhost", "root", "root", "test")cursor = db.cursor()cursor.execute('SELECT * FROM user')results = cursor.fetchall()for r in results:print (r)

十二、上下文管理

• 每次都连接关闭很麻烦，使用上下文管理，简化连接过程

import pymysqlimport contextlib# 定义上下文管理器，连接后自动关闭连接@contextlib.contextmanagerdef mysql(host='127.0.0.1', port=3306, user='root', passwd='', db='test',charset='utf8'):conn = pymysql.connect(host=host, port=port, user=user, passwd=passwd, db=db, charset=charset)cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)try:yield cursorfinally:conn.commit()cursor.close()conn.close()# 执行sqlwith mysql() as cursor:print(cursor)count = cursor.execute("select * from user")row_1 = cursor.fetchone()print row_count, row_1

到此，相信大家对"python怎么操作pymysql数据库"有了更深的了解，不妨来实际操作一番吧！这里是网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！