1.安装第三方库
pip install pymysql
2.在Python中使用
2.1基本使用
- 导包 -> 建立连接 -> 进行操作 -> 关闭数据库
from pymysql import Connection
conn = Connection(
host="10.10.100.220",
port=3306,
user="root",
password="123456",
autocommit=True
)
print(conn.get_server_info())
conn.close()
2.2执行建表SQL
- 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 关闭连接:
from pymysql import Connection
conn = Connection(
host="10.10.100.220",
port=3306,
user="root",
password="123456",
autocommit=True
)
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("CREATE TABLE test01 (id INT , name varchar(20))")
conn.close()
2.3执行SQL语句
- 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 获取查询数据,执行操作 -> 关闭数据库
from pymysql import Connection
conn = Connection(
host="10.10.100.220",
port=3306,
user="root",
password="123456",
autocommit=True
)
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("SELECT * FROM test01")
results: tuple = cursor.fetchall()
for result in results:
print(result)
conn.close()
2.4执行插入SQL
- 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 提交行为 -> 关闭数据库
from pymysql import Connection
conn = Connection(
host="10.10.100.220",
port=3306,
user="root",
password="123456",
autocommit=True
)
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("INSERT INTO test01 VALUES(1,'张三')")
conn.commit()
conn.close()
2.5执行修改操作
- 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 提交行为 -> 关闭数据库
from pymysql import Connection
conn = Connection(
host="10.10.100.220",
port=3306,
user="root",
password="123456",
autocommit=True
)
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("UPDATE test01 SET name = '李四' where id = 1")
conn.close()
2.6执行删除操作
- 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 提交行为 -> 关闭数据库
from pymysql import Connection
conn = Connection(
host="10.10.100.220",
port=3306,
user="root",
password="123456",
autocommit=True
)
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("DELETE FROM test01 where id = 1")
conn.close()
2.7小结
- pymysql在执行数据插入或其它产生数据更改的SQL语句时,
默认是需要提交更改
的,即,需要通过代码“确认”这种更改行为。 - 如果不想手动commit确认,可以在构建连接对象的时候,设置
自动commit的属性
。 - 查询后,使用
游标对象.fetchall()
可得到全部的查询结果封装入嵌套元组内 - 可使用
游标对象.execute()
执行SQL语句