版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
# -*- coding: utf-8 -*-
"""
Created on Wed Oct 9 14:49:11 2019
"""
import os
import configparser
import pandas as pd
from sqlalchemy import create_engine
def connection():
def login():
CONF = r'C:\Users\cc\Cs\c.s.conf'
conf = configparser.ConfigParser()
if os.path.exists(CONF):
conf.read(CONF)
host = conf.get('SQL Server', 'ip')
port = conf.get('SQL Server', 'port')
dbname = conf.get('SQL Server', 'dbname')
return host, port, dbname
try:
engine = create_engine(r'mssql+pymssql://@%s:%s/%s' % login())
except Exception as e:
print('Connect failed %s' % e)
else:
print('Connect success')
return engine
con = connection()
# SQL Server 查询基本信息表
# 查询基本信息 表头
sql = ''' SELECT *
FROM INFORMATION_SCHEMA.COLUMNS
WHERE table_name='basicInfo'
'''
title = [i[3] for i in con.execute(sql).fetchall()]
# 查询基本信息 data
sql = ''' SELECT *
FROM basicInfo
ORDER BY Id DESC
'''
data = con.execute(sql).fetchall()
# 合并表头 & 基本信息
df_b = pd.DataFrame(data, columns=title)