插入行

原文： https://thepythonguru.com/inserting-rows/

于 2020 年 1 月 7 日更新

Insert 语句用于在 mysql 中插入记录。

语法： INSERT INTO <some table> (<some column names>) VALUES("<some values>");

示例 1：

  1. from __future__ import print_function
  3. import MySQLdb as my
  5. db = my.connect(host="127.0.0.1",
  6. user="root",
  7. passwd="",
  8. db="world"
  9. )
  11. cursor = db.cursor()
  13. sql = "insert into city VALUES(null, 'Mars City', 'MAC', 'MARC', 1233)"
  15. number_of_rows = cursor.execute(sql)
  16. db.commit()   # you need to call commit() method to save 
  17.               # your changes to the database
  19. db.close()

该程序在城市表中插入一个新城市，注意对db.commit()的使用，该方法将您的更改保存到数据库中。

示例 2：

  1. from __future__ import print_function
  3. import MySQLdb as my
  5. db = my.connect(host="127.0.0.1",
  6. user="root",
  7. passwd="",
  8. db="world"
  9. )
  11. cursor = db.cursor()
  13. name = "Some new city"
  14. country_code = 'PSE'
  15. district = 'Someyork'
  16. population = 10008
  18. sql = "insert into city VALUES(null, '%s', '%s', '%s', %d)" % \
  19.  (name, country_code , district, population)
  21. number_of_rows = cursor.execute(sql)
  22. db.commit()
  24. db.close()

请注意，在第 18 行中使用了反斜杠（\）字符。\字符用于将 python 语句拆分为多行。

插入多行

要在表中插入多行，请使用游标对象的executemany()方法。

语法： cursor_object.executemany(statement, arguments)

statement：包含要执行的查询的字符串。

arguments：一个包含要在insert语句中使用的值的序列。

让我们举个例子。

  1. from __future__ import print_function
  3. import MySQLdb as my
  5. db = my.connect(host="127.0.0.1",
  6. user="root",
  7. passwd="",
  8. db="world"
  9. )
  11. cursor = db.cursor()
  12. name = "Some new city"
  14. country_code = 'SNC'
  16. district = 'Someyork'
  18. population = 10008
  20. data = [
  21. ('city 1', 'MAC', 'distrct 1', 16822),
  22. ('city 2', 'PSE', 'distrct 2', 15642),
  23. ('city 3', 'ZWE', 'distrct 3', 11642),
  24. ('city 4', 'USA', 'distrct 4', 14612),
  25. ('city 5', 'USA', 'distrct 5', 17672),
  26. ]
  28. sql = "insert into city(name, countrycode, district, population) 
  29. VALUES(%s, %s, %s, %s)"
  31. number_of_rows = cursor.executemany(sql, data)
  32. db.commit()
  34. db.close()

在下一篇文章中，我们讨论如何处理错误。