python连接mysql多sql语句查询

对于多sql语句查询，使用的方法是将脚本都放入txt中，通过一个循环，将语句依次读入,并执行

#!/usr/bin/python

# -*- coding: utf-8 -*-

import pymysql;

import sshtunnel;

def get_sshData2(sql):

    with sshtunnel.SSHTunnelForwarder(

        ssh_address_or_host='***.**.**.***',

        ssh_port=**,

        ssh_username='*****',

        ssh_password='******',

        remote_bind_address=('*****',3306)

    ) as tunnel:

        conn=pymysql.connect(host='****',user='****', passwd='*****', db='****', port=*****, charset='utf8');

        cursor = conn.cursor();

        cursor.execute(sql);

        # 使用 fetchone() 方法获取单条数据.

        results = cursor.fetchall()

        print(results)

        # 关闭数据库连接

        conn.close()

    # 返给结果给函数调用者。

        return results

def testSSHDB(sql):

    #sql = "select from_unixtime(reg_time, '%Y-%m-%d')as dd,count(*) from deayou_users where from_unixtime(reg_time, '%Y-%m')='2018-02'group by dd ";

    # get_sshData(sql);

    results=get_sshData2(sql);

#调用上面的方法 将数据写入

f2 = open("C:/Users/Miller/Desktop/sql_1.txt","r")

lines = f2.readlines()

for line3 in lines:

    line3 = line3.strip('\n');

    if line3!='':

      testSSHDB(line3)

else:  '停止执行'