python >>> sql >>> conn >>> pyodbc

python >>> sql >>> conn

 

import pyodbc

import pandas as pd

 

conn = pyodbc.connect(server='******', user='sa', password='******', database="*****",DRIVER='{SQL Server}')

sql = "select * from table"

data = pd.read_sql(sql,conn)

df = pd.DataFrame(data)

 

unique() # 去重

tolist() # 转换列表

---------------------------------------

### 封装 函数 调用

 

def get_mysqldatas(sql):

# 跟数据库建立连接

#dao# conn = pms.connect(host='服务器地址', user='用户名', passwd='密码', database='数据库', port=3306, charset="utf8")

    conn = pyodbc.connect(server='*****', user='sa', password='**', database="***",DRIVER='{SQL Server}')

    cur = conn.cursor() # 使用 cursor() 方法创建一个游标对象

    cur.execute(sql) # 使用 execute() 方法执行 SQL

    datas = cur.fetchall() # 获取所需要的数据

    cur.close() # 关闭连接

return datas # 返回所需的数据

 

sqlans = "SELECT datename(day,零售日期)+'日' AS day, datename(dw,零售日期) AS dw, SUM(销售数量) QTY, SUM(实收金额) AS VAL 

FROM V_DING_SALE 

WHERE datediff(mm,零售日期,getdate()) = 0

GROUP BY 零售日期 ORDER BY 零售日期"

 

data_ans = get_mysqldatas(sqlans)