上代码
#数据库mysql测试
#
import mysql.connector
def getdb():
# 链接到数据库 服务器 ，用户名，密码 ，数据库名称
mydb = mysql.connector.connect(host="localhost", user="root", passwd="wanmait", database="blogsys")
return mydb
#查询方法
def select():
mydb = getdb()
#print(mydb)
mycursor = mydb.cursor()
#执行sql语句
mycursor.execute("select * from blog")
#获取查询的结果
data = mycursor.fetchall()
for row in data:
print(row)
mydb.close()
#添加数据方法
def addBlog(blog):
#测试添加记录
mydb = getdb()
mycursor = mydb.cursor()
sql = "INSERT INTO blog (title,content,author,header,pubTime) VALUES(%s,%s,%s,'header1.jpg',NOW())"
vals = (blog["title"],blog["content"],"新浪")
#传入参数，执行sql
mycursor.execute(sql,vals)
mydb.commit()
mydb.close()
#addBlog({"title":"这是一个正经的测试","content":"很正经"})
0条评论
点击登录参与评论