# -*- 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()原文：https://www.cnblogs.com/pythonwl/p/14271431.html
如果您也喜欢它,动动您的小指点个赞吧
602392714
清零编程群