python executemany指定写入表-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

python executemany指定写入表

蛮大人123 2016-02-08 11:32:18 2089

1
sql语句如上,需要对dbname定义我试了在参数那里加上表名的位置,失败:
2
用++带入表名也不行:
3
请问该如何处理?

SQL Python
分享到
取消 提交回答
全部回答(1)
  • 蛮大人123
    2019-07-17 18:39:33

    刚敲了一下代码,executemany执行时最好对应个数。

    #!/usr/bin/env python
    # -- coding:utf-8 --
    
    import logging
    import MySQLdb
    
    class _MySQL(object):
         def __init__(self, host, port, user, passwd, db, charset='utf8'):
            self.conn = MySQLdb.connect(
                    host = host,
                    port = port,
                    user = user,
                    passwd = passwd,
                    db = db,
                    charset = charset)
    
        def get_cursor(self):
            return self.conn.cursor()
    
        def query(self, sql):
            cursor = self.get_cursor()  
            try:
                cursor.execute(sql, None)
                result = cursor.fetchall()  
            except Exception, e:
                logging.error("mysql query error: %s", e)
                return None
            finally:
                cursor.close()
            return result
    
        def execute(self, sql, param=None):
            cursor = self.get_cursor()
            try:
                cursor.execute(sql, param)
                self.conn.commit()
                affected_row = cursor.rowcount
            except Exception, e:
                logging.error("mysql execute error: %s", e)
                return 0
            finally:
                cursor.close()
            return affected_row
    
        def executemany(self, sql, params=None):
            cursor = self.get_cursor()
            try:
                cursor.executemany(sql, params)
                self.conn.commit()
                affected_rows = cursor.rowcount
            except Exception, e:
                logging.error("mysql executemany error: %s", e)
                return 0
            finally:
                cursor.close()
            return affected_rows
    
        def close(self):
            try:
                self.conn.close()
            except:
                pass
    
        def __del__(self):
            self.close()
    
    
    host = 'localhost'
    port = 3306
    user = 'root'
    passwd = '123456'
    db = 'foo'
    
    mysql = _MySQL(host, port, user, passwd, db)
    
    def create_table():
        table = """
                CREATE TABLE IF NOT EXISTS `watchdog`(
                    `id` int(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
                    `name` varchar(100),
                    `price` int(11) NOT NULL DEFAULT 0
                ) ENGINE=InnoDB charset=utf8;
                """
        print mysql.execute(table)
    
    def insert_data():
        params = [('dog_%d' % i, i) for i in xrange(12)]
        sql = "INSERT INTO `watchdog`(`name`,`price`) VALUES(%s,%s);"   
        print mysql.executemany(sql, params) 
    
    if __name__ == '__main__':
        create_table()
        insert_data()
    0 0
数据库
使用钉钉扫一扫加入圈子
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

推荐文章
相似问题