阿里云网站搭建教程,有没有专门做二手车网站,微信小程序开发视频教程,青岛做外贸网站Python3连接MySQL本文介绍Python3连接MySQL的第三方库--PyMySQL的基本使用。PyMySQL介绍PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库#xff0c;Python2中则使用mysqldb。Django中也可以使用PyMySQL连接MySQL数据库。PyMySQL安装pip install pymysql连接数据…Python3连接MySQL本文介绍Python3连接MySQL的第三方库--PyMySQL的基本使用。PyMySQL介绍PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库Python2中则使用mysqldb。Django中也可以使用PyMySQL连接MySQL数据库。PyMySQL安装pip install pymysql连接数据库注意事项在进行本文以下内容之前需要注意你有一个MySQL数据库并且已经启动。你有可以连接该数据库的用户名和密码你有一个有权限操作的database基本使用# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()# 定义要执行的SQL语句sql CREATE TABLE USER1 (id INT auto_increment PRIMARY KEY ,name CHAR(10) NOT NULL UNIQUE,age TINYINT NOT NULL)ENGINEinnodb DEFAULT CHARSETutf8;# 执行SQL语句cursor.execute(sql)# 关闭光标对象cursor.close()# 关闭数据库连接conn.close()返回字典格式数据# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句并且将结果作为字典返回的游标cursor conn.cursor(cursorpymysql.cursors.DictCursor)# 定义要执行的SQL语句sql CREATE TABLE USER1 (id INT auto_increment PRIMARY KEY ,name CHAR(10) NOT NULL UNIQUE,age TINYINT NOT NULL)ENGINEinnodb DEFAULT CHARSETutf8;# 执行SQL语句cursor.execute(sql)# 关闭光标对象cursor.close()# 关闭数据库连接conn.close()注意charset“utf8”编码不要写成utf-8增删改查操作增# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()sql INSERT INTO USER1(name, age) VALUES (%s, %s);username Alexage 18# 执行SQL语句cursor.execute(sql, [username, age])# 提交事务conn.commit()cursor.close()conn.close()插入数据失败回滚在执行增删改操作时如果不想提交前面的操作可以使用 rollback() 回滚取消操作。# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()sql INSERT INTO USER1(name, age) VALUES (%s, %s);username Alexage 18try:# 执行SQL语句cursor.execute(sql, [username, age])# 提交事务conn.commit()except Exception as e:# 有异常回滚事务conn.rollback()cursor.close()conn.close()获取插入数据的ID(关联操作时会用到)# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()sql INSERT INTO USER1(name, age) VALUES (%s, %s);username Alexage 18try:# 执行SQL语句cursor.execute(sql, [username, age])# 提交事务conn.commit()# 提交之后获取刚插入的数据的IDlast_id cursor.lastrowidexcept Exception as e:# 有异常回滚事务conn.rollback()cursor.close()conn.close()批量执行# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()sql INSERT INTO USER1(name, age) VALUES (%s, %s);data [(Alex, 18), (Egon, 20), (Yuan, 21)]try:# 批量执行多条插入SQL语句cursor.executemany(sql, data)# 提交事务conn.commit()except Exception as e:# 有异常回滚事务conn.rollback()cursor.close()conn.close()删# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()sql DELETE FROM USER1 WHERE id%s;try:cursor.execute(sql, [4])# 提交事务conn.commit()except Exception as e:# 有异常回滚事务conn.rollback()cursor.close()conn.close()改# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()# 修改数据的SQL语句sql UPDATE USER1 SET age%s WHERE name%s;username Alexage 80try:# 执行SQL语句cursor.execute(sql, [age, username])# 提交事务conn.commit()except Exception as e:# 有异常回滚事务conn.rollback()cursor.close()conn.close()查查询单条数据# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()# 查询数据的SQL语句sql SELECT id,name,age from USER1 WHERE id1;# 执行SQL语句cursor.execute(sql)# 获取单条查询数据ret cursor.fetchone()cursor.close()conn.close()# 打印下查询结果print(ret)查询多条数据# 导入pymysql模块import pymysql# 连接databaseconn pymysql.connect(host“你的数据库地址”, user“用户名”,password“密码”,database“数据库名”,charset“utf8”)# 得到一个可以执行SQL语句的光标对象cursor conn.cursor()# 查询数据的SQL语句sql SELECT id,name,age from USER1;# 执行SQL语句cursor.execute(sql)# 获取多条查询数据ret cursor.fetchall()cursor.close()conn.close()# 打印下查询结果print(ret)进阶用法# 可以获取指定数量的数据cursor.fetchmany(3)# 光标按绝对位置移动1cursor.scroll(1, modeabsolute)# 光标按照相对位置(当前位置)移动1cursor.scroll(1, moderelative)