[大数据]python连接Sql Server数据库

pip install pymssql #若没有该模块，需要下载

书写为函数

def SQLServer_connect(config_dict):
    '''
    SQLServer 数据库连接
    '''
    import pymssql #引入pymssql模块 
    connect=pymssql.connect(**config_dict)
    return connect

def executeSQL(config_dict,sql):
    '''
    执行给定的SQL语句
    '''
    import pandas as pd
    connect=SQLServer_connect(config_dict)
    cursor=connect.cursor() 
    cursor.execute(one_sql)
    rows = cursor.fetchall()
    df = pd.DataFrame(rows, columns=[x[0] for x in cursor.description])
    return df
    connect.close()

函数调用

#数据库连接配置
config_dict={
            'user':'账户',
            'password':'密码',
            'host':'服务器名',
            'database':'数据库名'
            }
# sql语法
one_sql = "select 小区名称,城市,区县 from Project_gaode"
#函数调用
executeSQL(config_dict,one_sql)

非函数写法，顺序执行

创建连接，执行sql语句

import pymssql #引入pymssql模块 
import pandas as pd
connect = pymssql.connect('服务器名', '账户', '密码', '数据库名') #服务器名,账户,密码,数据库名
if connect:
    print("连接成功!")

cursor = connect.cursor()   #创建一个游标对象,python里的sql语句都要通过cursor来执行
sql = "select 小区名称,城市,区县 from Project_gaode"
cursor.execute(sql)   #执行sql语句

方法一：使用 fetchone() 方法，将结果返回

row = cursor.fetchone()  #返回结果数据的一行，返回一个单行的数据对象，row.

# 将SQL查询结果转换为DataFrame
df = pd.read_sql(sql, connect) 
connect.close()   #关闭数据库连接

方法二：使用 fetchall() 方法，将结果返回

rows = cursor.fetchall() #获得所有数据，返回一个list对象，每行就是一个tuple元组。
connect.close()   #关闭数据库连接
#输出为DataFrame
df = pd.DataFrame(rows, columns=[x[0] for x in cursor.description])