數(shù)據(jù)庫(kù)中最好插入Null值。

在python中，暫時(shí)沒(méi)找到通過(guò)sql語(yǔ)句的方式插入Null值。

def insert_sample_data(self, values): # added self since you are referencing it below with self.con.cursor() as cur: sql = 'insert into sampletable values (%s, %s, %s)' # Use %s for parameters cur.executemany(sql, values) # Pass the list of tuples directly self.con.commit() list1 = [(1100, ’abc’, ’{'1209': 'Y', '1210': 'Y'}’), (1100, ’abc’, None)]self.insert_sample_data(list1) # pass the list directly

補(bǔ)充：python連接數(shù)據(jù)庫(kù)插入數(shù)據(jù)庫(kù)數(shù)據(jù)所碰到的坑

Python中插入數(shù)據(jù)時(shí)執(zhí)行后，沒(méi)有報(bào)任何錯(cuò)誤，但數(shù)據(jù)庫(kù)中并沒(méi)有出現(xiàn)新添加的數(shù)據(jù)

缺少提交操作。

Python操作數(shù)據(jù)庫(kù)時(shí)，如果對(duì)數(shù)據(jù)表進(jìn)行修改/刪除/添加等控制操作，系統(tǒng)會(huì)將操作保存在內(nèi)存，只有執(zhí)行commit()，才會(huì)將操作提交到數(shù)據(jù)庫(kù)。

import pymysql class Connection: def __init__(self): self.host = ’localhost’ self.user = ’nameit’ self.password = ’YES’ self.port = 3306 self.db = ’Xomai’ def connection(self): db = pymysql.connect(host=self.host, user=self.user, password=self.password, port=self.port, db=self.db) cur = db.cursor() return db, cur def create_table(self, cur): sql = '''CREATE TABLE `activity_feedback` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `inst_id` bigint(20) DEFAULT NULL COMMENT ’ID’, `broadcast_id` bigint(20) DEFAULT NULL COMMENT ’你好’, `student_id` bigint(20) DEFAULT NULL COMMENT ’學(xué)生ID’, `content` varchar(1024) DEFAULT NULL COMMENT ’學(xué)員內(nèi)容’, `comment` varchar(255) DEFAULT NULL COMMENT ’注釋’, `gmt_create` datetime DEFAULT NULL, `gmt_modify` datetime DEFAULT NULL, PRIMARY KEY (`id`), KEY `activity_feedback_student_id_index` (`student_id`) ) ENGINE = InnoDB AUTO_INCREMENT = 1050 DEFAULT CHARSET = utf8mb4 COMMENT = ’學(xué)員表’''' cur.execute(sql) def insert(self, id, inst_id, broadcast_id, student_id, content, comment, gmt_create, gmt_modify): sql = '''INSERT INTO `activity_feedback` ( `id`, `inst_id`, `broadcast_id`, `student_id`, `content`, `comment`, `gmt_create`, `gmt_modify`) VALUES (’{}’,’{}’,’{}’,’{}’,’{}’,’{}’,’{}’,’{}’)'''.format(id, inst_id, broadcast_id, student_id, content, comment, gmt_create, gmt_modify) try: self.connection()[1].execute(sql) self.connection()[0].commit() except: self.connection()[0].rollback()if __name__ == ’__main__’: conn = Connection() conn.insert(123, 123, 324, 3451, ’ajdf’, ’sdfs’, ’2013-2-5’, ’2014-3-4’)

咋一看好像也有commit呀，怎么一直在數(shù)據(jù)庫(kù)沒(méi)有，再仔細(xì)看看

try: self.connection()[1].execute(sql) self.connection()[0].commit() except: self.connection()[0].rollback()

connection()調(diào)用方法方法返回的對(duì)象是同一個(gè)嗎？

并不是，心累，搞了半天，只怪自己還太嫩。

try: cons = self.connection() cons[1].execute(sql) cons[0].commit() cons[0].close() except: cons[0].rollback()

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持好吧啦網(wǎng)。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。