1. 程式人生 > >python連線資料庫插入資料庫資料所碰到的坑

python連線資料庫插入資料庫資料所碰到的坑

Python中插入資料時執行後,沒有報任何錯誤,但資料庫中並沒有出現新新增的資料

原因:缺少提交操作

解決方案:Python操作資料庫時,如果對資料表進行修改/刪除/新增等控制操作,系統會將操作儲存在記憶體,只有執行commit(),才會將操作提交到資料庫。

但是總有你想不到的坑程式碼如下:

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 '學生ID',
                  `content` varchar(1024) DEFAULT NULL COMMENT '學員內容',
                  `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 = '學員表'"""

        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呀,怎麼一直在資料庫沒有,再仔細看看

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

connection()呼叫方法方法返回的物件是同一個嗎?

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

正確寫法:

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