怎么在python中利用PYMYSQL对MYSQL数据库进行连接?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
创新互联于2013年成立,先为波密等服务建站,波密等地企业,进行企业商务咨询服务。为波密企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。什么是MYSQL数据库
MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,目前属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是好的 RDBMS (Relational Database Management System,关系数据库管理系统) 应用软件之一。
PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb。
PyMySQL 遵循 Python 数据库 API v2.0 规范,并包含了 pure-Python MySQL 客户端库。
pip install pymysql
1、首先导入PyMySQL模块
2、连接数据库(通过connect())
3、创建一个数据库对象 (通过cursor())
4、进行对数据库做增删改查
# coding:utf-8 import pymysql # 连接数据库 count = pymysql.connect( host = 'xx.xxx.xxx.xx', # 数据库地址 port = 3306, # 数据库端口号 user='xxxx', # 数据库账号 password='XXXX', # 数据库密码 db = 'test_sll') # 数据库表名# 创建数据库对象 db = count.cursor()
db.fetchone()获取一条数据
db.fetchall()获取全部数据
# coding:utf-8 import pymysql # 连接数据库 count = pymysql.connect( host = 'xx.xxx.xxx.xx', # 数据库地址 port = 3306, # 数据库端口号 user='xxxx', # 数据库账号 password='xxxx', # 数据库密码 db = 'test_sll') # 数据库名称 # 创建数据库对象 db = count.cursor() # 写入SQL语句 sql = "select * from students " # 执行sql命令 db.execute(sql) # 获取一个查询 # restul = db.fetchone() # 获取全部的查询内容 restul = db.fetchall() print(restul) db.close()
commit() 执行完SQL后需要提交保存内容
# coding:utf-8 import pymysql # 连接数据库 count = pymysql.connect( host = 'xx.xxx.xxx.xx', # 数据库地址 port = 3306, # 数据库端口号 user='xxx', # 数据库账号 password='xxx', # 数据库密码 db = 'test_sll') # 数据库表名 # 创建数据库对象 db = count.cursor() # 写入SQL语句 sql = "update students set age = '12' WHERE id=1" # 执行sql命令 db.execute(sql) # 保存操作 count.commit() db.close()
# coding:utf-8 import pymysql # 连接数据库 count = pymysql.connect( host = 'xx.xxx.xxx.xx', # 数据库地址 port = 3306, # 数据库端口号 user='xxxx', # 数据库账号 password='xxx', # 数据库密码 db = 'test_sll') # 数据库表名 # 创建数据库对象 db = count.cursor() # 写入SQL语句 sql = "delete from students where age = 12" # 执行sql命令 db.execute(sql) # 保存提交 count.commit() db.close()
新增数据这里涉及到一个事务问题,事物机制可以保证数据的一致性,比如插入一个数据,不会存在插入一半的情况,要么全部插入,要么都不插入
# coding:utf-8 import pymysql # 连接数据库 count = pymysql.connect( host = 'xx.xxx.xxx.xx', # 数据库地址 port = 3306, # 数据库端口号 user='xxxx', # 数据库账号 password='xxx', # 数据库密码 db = 'test_sll') # 数据库表名 # 创建数据库对象 db = count.cursor() # 写入SQL语句 sql = "insert INTO students(id,name,age)VALUES (2,'安静','26')" # 执行sql命令 db.execute(sql) # 保存提交 count.commit() db.close()
到这可以发现除了查询不需要保存,其他操作都要提交保存,并且还会发现删除,修改,新增,只是修改了SQL,其他的没什么变化
创建表首先我们先定义下表内容的字段
字段名 | 含义 | 类型 |
id | id | varchar |
name | 姓名 | varchar |
age | 年龄 | int |
# coding:utf-8 import pymysql # 连接数据库 count = pymysql.connect( host = 'xx.xxx.xxx.xx', # 数据库地址 port = 3306, # 数据库端口号 user='xxxx', # 数据库账号 password='xxx', # 数据库密码 db = 'test_sll') # 数据库表名 # 创建数据库对象 db = count.cursor() # 写入SQL语句 sql = 'CREATE TABLE students (id VARCHAR(255) ,name VARCHAR(255) ,age INT)' # 执行sql命令 db.execute(sql) db.close()
看完上述内容,你们掌握怎么在python中利用PYMYSQL对MYSQL数据库进行连接的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!