概述
import pymysql
class mysql:
# 实现连接数据库,执行sql
def connect_mysql_and_execute_sql(self, mysql_ip, mysql_port, mysql_username, mysql_password,mysql_database, sql):
db = pymysql.connect(host=mysql_ip, port= mysql_port, user=mysql_username, password=mysql_password,
database=mysql_database, charset=“utf8”) # 连接数据库,将数据库对象赋值给变量db
# 给数据库对象创建一个游标,将游标对象赋值给cur
cur = db.cursor()
# 执行SQL语句
cur.execute(sql)
db.commit() # 语句执行后生效
# 接收所有返回的数据
data = cur.fetchall() # 接收所有返回数据
cur.close() # 关闭游标
db.close() #关闭数据库
return data # 返回查询到的数据
if name == “main”:
sql1= “select * from oa_tbl_employee”
data = mysql().connect_mysql_and_execute_sql(“localhost”, 13306, “root”, “3.1415926”, “stfoa”, sql1)
print(data)
最后
以上就是现实毛巾为你收集整理的Python中使用pymsql实现数据库连接,执行sql语句的全部内容,希望文章能够帮你解决Python中使用pymsql实现数据库连接,执行sql语句所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复