import pymysql
db_host = "localhost"
db_name = "mydatabse"
table_name = "Student"
db_user = "root"
db_pass = "745269"
query_insert = "INSERT INTO " + table_name + " (stu_id, stu_name) VALUES (%s, %s) "
class Student:
id = 0
name = ""
def __init__(self, sid, name):
self.id = sid
self.name = name
def insert_record(rec):
#print((rec.id, rec.name))
con = pymysql.connect(host=db_host, user=db_user, password=db_pass, database=db_name)
cur = con.cursor()
cur.execute(query_insert, (rec.id, rec.name))
#$cur.execute("INSERT INTO Student VALUES (%s, %s)", (3, 'Qwerty'))
r1 = Student(3, "Qwerty")
insert_record(r1)
我正在尝试使用pymysql模块将新行插入数据库。我打算像INSERT一样全局定义所有查询。我想我缺少查询的某些格式,但到目前为止仍无法指出。任何帮助都将受到感激。
根据https://pymysql.readthedocs.io/en/latest/user/examples.html,“默认情况下,连接不会自动提交。因此,您必须提交以保存更改。”
将导致:
import pymysql
db_host = "localhost"
db_name = "mydatabse"
table_name = "Student"
db_user = "root"
db_pass = "745269"
query_insert = "INSERT INTO " + table_name + " (stu_id, stu_name) VALUES (%s, %s) "
class Student:
id = 0
name = ""
def __init__(self, sid, name):
self.id = sid
self.name = name
def insert_record(rec):
#print((rec.id, rec.name))
con = pymysql.connect(host=db_host, user=db_user, password=db_pass, database=db_name)
cur = con.cursor()
cur.execute(query_insert, (rec.id, rec.name))
#$cur.execute("INSERT INTO Student VALUES (%s, %s)", (3, 'Qwerty'))
con.commit() # Added this commit call
r1 = Student(3, "Qwerty")
insert_record(r1)