API

基础操作：增加、删除、修改、查询
connection对象支持的方法如下：
cursor():使用该连接创建并返回游标
commit():提交当前事务
rollback():回滚当前事务
close():关闭连接
cursor对象支持的方法如下：
execute(op):执行一个数据库的查询命令
fetchone():取得结果集的下一行
fetchmany(size):获取结果集的下几行
fetchall():获取结果集中的所有行
rowcount():返回数据条数或影响行数
close():关闭游标对象
向数据库新增数据：
op = “insert into table_name(column1,column2,…,columnN) values(value1,value2,…,valueN)”
cursor.execute(op)
删除数据库中的数据：
op = “delete from table_name where condition_statement”
cursor.execute(op)
修改数据库中的数据：
op = “update table_name set column1=value1,column2=value2,…,columnN=valueN where condition_statement”
cursor.execute(op)
查询数据库中的数据：
op = “select * from table_name where condition_statement”
cursor.execute(op)

Example

The following examples make use of a simple table

mysql

  1. CREATE TABLE `users` (
  2.     `id` int(11) NOT NULL AUTO_INCREMENT,
  3.     `email` varchar(255) COLLATE utf8_bin NOT NULL,
  4.     `password` varchar(255) COLLATE utf8_bin NOT NULL,
  5.     PRIMARY KEY (`id`)
  6. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin
  7. AUTO_INCREMENT=1 ;

python

  1. import pymysql.cursors
  3. # Connect to the database
  4. connection = pymysql.connect(host='localhost',
  5.                              user='user',
  6.                              password='passwd',
  7.                              database='db',
  8.                              cursorclass=pymysql.cursors.DictCursor)
  10. with connection:
  11.     with connection.cursor() as cursor:
  12.         # Create a new record
  13.         sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"
  14.         cursor.execute(sql, ('webmaster@python.org', 'very-secret'))
  16.     # connection is not autocommit by default. So you must commit to save
  17.     # your changes.
  18.     connection.commit()
  20.     with connection.cursor() as cursor:
  21.         # Read a single record
  22.         sql = "SELECT `id`, `password` FROM `users` WHERE `email`=%s"
  23.         cursor.execute(sql, ('webmaster@python.org',))
  24.         result = cursor.fetchone()
  25.         print(result)

例1 insert

  1. from pymysql import *
  4. def main():
  5.   # 创建connection连接
  6.   conn = connect(host='ip地址', port='3306 端口，int类型', database='数据库名', user='使用者名字',
  7.           password='密码', charset='utf8')
  8.   # 获取cursor对象
  9.   cs1 = conn.cursor()
  10.   # 执行sql语句
  11.   query = 'insert into 表名(列名1, 列名2, 列名3, 列名4, 列名5, 列名6) values(%s, %s, %s, %s, %s, %s)'
  12.   #列名1 = 值1
  13.   #列名2 = 值2
  14.   #列名3 = 值3
  15.   #列名4 = 值4
  16.   #列名5 = 值5
  17.   #列名6 = 值6
  18.   values = (列名1 值, 列名2 值, 列名3 值, 列名4 值, 列名5 值, 列名6 值)
  19.   # 执行提交
  20.   cs1.execute(query, values)
  22.   # 提交之前的操作，如果之前已经执行多次的execute，那么就都进行提交
  23.   conn.commit()
  25.   # 关闭cursor对象
  26.   cs1.close()
  27.   # 关闭connection对象
  28.   conn.close()
  31. if __name__ == '__main__':
  32.   main()

例2 查询

  1. cur = db.cursor()
  2. sql = 'SELECT * FROM sale_data WHERE 位置 IN (%s,%s,%s)'
  3. cur.execute(sql,("江苏“，”浙江“，”上海“））
  4. result = cur.fetchall()
  5. for item in result:
  6.     print(item)

sql

  1. select column_name,column_comment,data_type,column_type 
  2. from information_schema.columns 
  3. where table_name='表名' and table_schema='数据库名称';

例3

  1. sql = 'INSERT INTO sale_data(商品，价格，成交量，卖家，位置) VALUES(%s,%s,%s,%s,%s)'
  2. cur.execute(sql,("连衣裙“，298,10000，”某店“，”北京“))
  3. db.commit()

error

insert

pymysql.err.ProgrammingError: (1064, “You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near

参考
https://pymysql.readthedocs.io/en/latest/index.html
https://www.cnblogs.com/zhuozige/p/13131200.html
https://www.w3school.com.cn/sql/sql_delete.asp