当前位置：首页 > news >正文

Python使用zdppy_mysql操作MySQL和MariaDB数据库快速入门教程

news 2025/7/16 7:45:15

zdppy_mysql

使用python操作MySQL

项目开源地址：https://github.com/zhangdapeng520/zdppy_mysql

安装

pip install zdppy_mysql

使用教程

连接MySQL

import zdppy_mysql
from config import host, username, password, database, port# 连接数据库
db = zdppy_mysql.connect(host,username,password,database,port,
)
print(db)

添加数据库

import zdppy_mysql
from config import host, username, password, database, port# 连接数据库
db = zdppy_mysql.connect(host,username,password,database,port,
)# 使用游标对象执行SQL语句
with db.cursor() as cur:# 创建数据库sql = "create database if not exists test"cur.execute(sql)# 查询所有数据库sql = "show databases"cur.execute(sql)print(cur.fetchall())

查询所有表

import zdppy_mysql
from config import host, username, password, database, port# 连接数据库
db = zdppy_mysql.connect(host,username,password,database,port,cursorclass=zdppy_mysql.cursors.DictCursor,
)# 使用游标对象执行SQL语句
with db.cursor() as cur:# 查询所有数据库sql = "show tables"cur.execute(sql)print(cur.fetchall())

添加表

import zdppy_mysql
from config import host, username, password, database, port# 连接数据库
db = zdppy_mysql.connect(host,username,password,database,port,cursorclass=zdppy_mysql.cursors.DictCursor,
)# 使用游标对象执行SQL语句
with db.cursor() as cur:# 查询所有数据库sql = "create table user(id int primary key auto_increment, name varchar(255))"cur.execute(sql)db.commit()

添加数据

import zdppy_mysql
from config import host, username, password, database, port# 连接数据库
db = zdppy_mysql.connect(host,username,password,database,port,cursorclass=zdppy_mysql.cursors.DictCursor,
)# 使用游标对象执行SQL语句
with db.cursor() as cur:cur.execute("insert into user(name) values(%s)", ("张三1",))cur.execute("insert into user(name) values(%s)", ("张三2",))cur.execute("insert into user(name) values(%s)", ("张三3",))# 必须加commit才会提交到数据库保存db.commit()

查询所有数据

import zdppy_mysql
from config import host, username, password, database, port# 连接数据库
db = zdppy_mysql.connect(host,username,password,database,port,cursorclass=zdppy_mysql.cursors.DictCursor,
)# 使用游标对象执行SQL语句
with db.cursor() as cur:# 查询所有数据库cur.execute("select * from user")print(cur.fetchall())