pymysql执行sql脚本

从网上搜索了半天也没有合适的，大多是以;分隔后直接执行, 但是这样会存在注释的问题。一般导出的sql文件中，都包含了大量的注释；

import pymysql

def mysql_init():
    # conf 包含mysql的一些配置
    con = pymysql.connect(host=conf.get('db', 'mysql_uri'),
                          port=conf.getint('db', 'mysql_port'),
                          user=conf.get('db', 'mysql_username'),
                          password=conf.get('db', 'mysql_password'),
                          charset='utf8')
    cur = con.cursor()
    cur.execute("create database test character set utf8;")
    con.close()
    sync_mysql_data('test', "test.sql")
    print '初始化mysql数据成功'


def sync_mysql_data(db, file):
    with open(file, "r") as f:  # 打开文件
        data = f.read()
        lines = data.splitlines()
        sql_data = ''
	# 将--注释开头的全部过滤，将空白行过滤
        for line in lines:
            if len(line) == 0:
                continue
            elif line.startswith("--"):
                continue
            else:
                sql_data += line
        sql_list = sql_data.split(';')[:-1]
        sql_list = [x.replace('\n', ' ') if '\n' in x else x for x in sql_list]
    con = pymysql.connect(host=conf.get('db', 'mysql_uri'),
                          port=conf.getint('db', 'mysql_port'),
                          user=conf.get('db', 'mysql_username'),
                          password=conf.get('db', 'mysql_password'),
                          database=db,
                          charset='utf8')
    cur = con.cursor()
    for sql_item in sql_list:
        print sql_item
        cur.execute(sql_item)
    con.close()