Python 链接Mysql数据库

参考链接:https://pypi.python.org/pypi/PyMySQL#downloads

import pymysql.cursors,xml.dom.minidom

# Connect to the database

connection = pymysql.connect(host='192.168.75.134',

                             user='sdo',

                             password='51..sdo',

                             db='sdo_config',

                             charset='utf8mb4',

                             cursorclass=pymysql.cursors.DictCursor)

def checkGameTask(connection):

    game_task_xml = open("gameTask_Check.xml",'w',encoding='utf-8')

    impl = xml.dom.minidom.getDOMImplementation()

    dom = impl.createDocument(None, 'RECORDS', None)

    root = dom.documentElement

    try:

        with connection.cursor() as cursor:

            sql = "SELECT `EventID`,`ScoreType`,`ScoreValue`,`TaskGate`,`TaskID`,`TaskState`,`TaskType`,`condExpr` FROM `gameTask`"

            cursor.execute(sql)

            results = cursor.fetchall()

            for row in results:

                cfg = dom.createElement('RECORD')

                cfg.setAttribute('TaskID','%s'%int(row.get('TaskID')))

                cfg.setAttribute('TaskType','%s'%int(row.get('TaskType')))

                cfg.setAttribute('EventID','%s'%int(row.get('EventID')))

                cfg.setAttribute('condExpr','%s'%int(row.get('condExpr')))

                cfg.setAttribute('TaskState','%s'%int(row.get('TaskState')))

                cfg.setAttribute('TaskGate','%s'%int(row.get('TaskGate')))

                cfg.setAttribute('ScoreType','%s'%int(row.get('ScoreType')))

                cfg.setAttribute('ScoreValue','%s'%int(row.get('ScoreValue')))

                root.appendChild(cfg)

            dom.writexml(game_task_xml, addindent='    ', newl='\n')

    finally:

        connection.close()

checkGameTask(connection)