sqlserver 数据库连接池

# -*- coding:utf-8 -*-
import pymssql
from DBUtils.PooledDB import PooledDB
from log_maker import logger


class Sql_conn:
    def __init__(self):
        # conn = pymssql.connect(server='ta-proddb-ceus.database.windows.net', database='linde_china',
        #                        user='linde_china_ecoa_opendata', password='xGBLmvvjOftTiPTuG2ZUTW7!2mV0Ec',
        #                        charset='utf8',
        #                        tds_version="7.0")
        server = 'ta-proddb-ceus.database.windows.net'
        port = 1433
        user = 'linde_china_ecoa_opendata'
        password = 'xGBLmvvjOftTiPTuG2ZUTW7!2mV0Ec'
        database = 'linde_china'
        self.pool = PooledDB(creator=pymssql, mincached=0, maxcached=0, maxconnections=10, blocking=True,
                             host=server, port=port, user=user, password=password, database=database, charset="utf8",
                             tds_version="7.0")

    def read_sql_one(self, sql, params=None):
        conn = self.pool.connection()
        cursor = conn.cursor()
        cursor.execute(sql, params)
        data = cursor.fetchall()
        cursor.close()
        conn.close()
        return data

conn_pool = None

class SqlServerCon(object):

    def __init__(self):
        server = 'ta-proddb-ceus.database.windows.net'
        port = 1433
        user = 'linde_china_ecoa_opendata'
        password = 'xGBLmvvjOftTiPTuG2ZUTW7!2mV0Ec'
        database = 'linde_china'
        self.pool = PooledDB(creator=pymssql, mincached=0, maxcached=0, maxshared=0, maxconnections=10, blocking=True,
                             host=server, port=port, user=user, password=password, database=database, charset="utf8",
                             tds_version="7.0")

    def read_sql_one(self, sql, params=None):
        conn = self.pool.connection()
        cursor = conn.cursor()
        cursor.execute(sql, params)
        data = cursor.fetchall()
        cursor.close()
        conn.close()
        return data


def get_sql_conn():
    global conn_pool
    if conn_pool is None:
        logger.info('实例化了连接池对象')
        conn_pool = SqlServerCon()
    return conn_pool



# logger.info('实例化了连接池对象')
# conn_pool = Sql_conn()