任何一种编程语言都有数据库交互能力,python也不例外。
Python3 使用 PyMySQL 连接数据库,并实现简单的增删改查。
关于PyMysql
PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb。
安装PyMysql
PyMysql的安装有多种方式,我这里用的ide时pycharm,解释器是anacanda,所以直接界面点击安装
如下图:
连接数据库并建表
新建create_table.py
import pymysql
db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai")
cursor = db_connect.cursor()
cursor.execute("DROP TABLE IF EXISTS t_ai_test")
print(cursor.rowcount)
sql_create_table = """CREATE TABLE t_ai_test (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql_create_table)
db_connect.commit()
print(cursor.rowcount)
cursor.close()
db_connect.close()
# 执行完之后发现数据库多了一张表
插入一条数据
insert.py
import pymysql
db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai")
cursor = db_connect.cursor()
sql_insert_table = """insert into t_ai_test
(FIRST_NAME,LAST_NAME,AGE,SEX,INCOME)
values ('he','shiyuan',18,'1',20000)"""
try:
cursor.execute(sql_insert_table)
db_connect.commit()
print(cursor.rowcount)
except Exception as e:
db_connect.rollback()
print("insert sql捕获到异常")
raise e
cursor.close()
db_connect.close()
# 查询数据库发现数据已经插入成功
修改
update.py
import pymysql
db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai")
cursor = db_connect.cursor()
sql_insert_table = """update t_ai_test
set INCOME = 30000 where FIRST_NAME = 'he' and LAST_NAME = 'shiyuan'"""
try:
cursor.execute(sql_insert_table)
db_connect.commit()
print(cursor.rowcount)
except Exception as e:
db_connect.rollback()
print("insert sql捕获到异常")
raise e
cursor.close()
db_connect.close()
查询
select.py
import pymysql
db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai")
cursor = db_connect.cursor()
sql_select_table = """select * from t_ai_test where FIRST_NAME = 'he' and LAST_NAME = 'shiyuan'"""
try:
cursor.execute(sql_select_table)
data = cursor.fetchall()
db_connect.commit()
if(len(data) > 0):
print(data)
else:
print("no data")
except Exception as e:
db_connect.rollback()
print("insert sql捕获到异常")
raise e
cursor.close()
db_connect.close()
删除
delete.py
import pymysql
db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai")
cursor = db_connect.cursor()
sql_delete_table = """delete from t_ai_test where FIRST_NAME = 'he' and LAST_NAME = 'shiyuan'"""
try:
cursor.execute(sql_delete_table)
data = cursor.fetchall()
db_connect.commit()
print(cursor.rowcount)
except Exception as e:
db_connect.rollback()
print("delete sql捕获到异常")
raise e
cursor.close()
db_connect.close()
总结
以上便是python3操作mysql数据库的增删改查操作。后续完善更新