1. pymysql 数据库调用

  • pymysql.connect(host,user,passwd,db,charset) 创建数据连接对象 返回db对象
  • db.cursor() 创建游标 返回cursor对象
  • db.commit() 提交事务
  • cursor.execute(sql) 执行指定sql语句
  • cursor.fetchall() 如果cursor有返回结果则使用此方法 读取返回结果
  • close() 关闭
  1. import pymysql
  2. #创建连接
  3. db = pymysql.connect(host='127.0.0.1',user='root',passwd='373213257',db='cov',charset='utf8')    #charset是utf8而不是utf-8
  6. #创建游标
  7. cursor=db.cursor()
  10. cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")   ## 使用 execute() 方法执行 SQL，如果表存在则删除
  13. sql = """CREATE TABLE EMPLOYEE (
  14.          FIRST_NAME  CHAR(20) NOT NULL,
  15.          LAST_NAME  CHAR(20),
  16.          AGE INT,  
  17.          SEX CHAR(1),
  18.          INCOME FLOAT )"""
  20. cursor.execute(sql)  #使用cursor.execute传入sql语句  sql存放是字符串
  22. cursor.close()  #关闭游标
  23. db.close()  #关闭数据库连接

读取结果

  1. sql ="""INSERT INTO history VALUES('2020-01-02',2,3,4,5,6,7)"""
  2. cursor.execute(sql)
  3. db.commit() #提交事务
  4. cursor.execute("select * from history")
  5. res = cursor.fetchall()
  6. print(res)