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

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

python executemany指定写入表

2016-02-08 11:32:18 2673 1

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

取消 提交回答
全部回答(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
相关问答

1

回答

maxcompute java sdk 有写入指定表分区的方法吗

2022-06-28 14:13:21 138浏览量 回答数 1

1

回答

Jupyter中R语言Rstudio导入包中的base表示什么?

2021-12-02 19:35:07 282浏览量 回答数 1

1

回答

Python列表方法list.extend(seq)的作用是什么?

2021-11-04 22:55:35 134浏览量 回答数 1

1

回答

python的数据类型list中的extend()功能是什么?

2021-11-02 20:55:59 304浏览量 回答数 1

1

回答

jython 在dos命令窗口运行报错?报错

2020-06-10 15:18:54 294浏览量 回答数 1

1

回答

Camelot(Python框架):指定备用EntityAdmin

2020-02-21 16:04:56 382浏览量 回答数 1

1

回答

初学Django,打开127.0.0.1:8000/admin/时,python.exe停止工作。

2019-12-07 13:54:58 3107浏览量 回答数 1

1

回答

scala spark rdd joing两个具有相同id的表

2018-12-19 15:46:16 1527浏览量 回答数 1

1

回答

(python)推荐算法中,RMSE,MAE的取值范围一般是多少?

2018-07-15 11:09:55 10500浏览量 回答数 1

1

回答

eclipse中怎么运用scrapy框架,我在Python在已经将scrapy装好了。

2016-05-31 14:55:13 3005浏览量 回答数 1
+关注
蛮大人123
我说我不帅他们就打我,还说我虚伪
0
文章
7733
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载