批量增加数据库数据

工作中，sit环境需要批量导入已经存在的数据库，以及账号密码，用来管理开发在sit环境执行db的行为。由于涉及到的db众多，手动从前端页面录入费时费力，

因此，写了个小脚本处理数据。

首先把所有数据库处理成列表：

def deal_text():
    database_list = []
    for line in open(r'C:xxxdatabases.txt'):
        line = line.strip().replace('
', ',')
        database_list.append(line)
    return database_list


if __name__ == '__main__':
    deal_text()

databse_list = ['rec', 'wfm']

接着执行数据库插入操作：

from sqlalchemy import create_engine, MetaData
from sqlalchemy import Table

engine = create_engine('mysql+cymysql://root:password@10.32.23.52:3306/xxx', echo=False)
metadata = MetaData(engine)
core_table = Table('core_databaselist', metadata, autoload=True)
conn = engine.connect()

def ex(databases_name):
    for database_name in databases_name:
        r = dict(
            connection_name=database_name,
            computer_room='Own',
            ip='xxx',
            username=database_name + '_testrw',
            port=xxx,
            password='xxx'
        )
        conn.execute(core_table.insert(), [r])


if __name__ == '__main__':
    # 填写数据库名称
    databases_name=[ 'oas', 'org', 'osp', 'pay', 'pes', 'pf_test', 'pms', 'pre', 'prs', 'sag', 'seal', 'sfm', 'sms', 'sonar']
    ex(databases_name)

这样就执行了数据库的批量插入了。注意安装sqlalchemy,cymysql