pip install pymssql

import pymssql

server = '(local)'
database = '訂單信息'
username = 'sa'
password = '123456'
# 連接到數(shù)據(jù)庫(kù)
conn = pymssql.connect(server=server, user=username, password=password, database=database,tds_version="7.0")#最后一個(gè)參數(shù)不是必須的
# 創(chuàng)建游標(biāo)對(duì)象
cursor = conn.cursor()
print('連接成功！')
# 關(guān)閉數(shù)據(jù)庫(kù)連接
conn.close()

#coding=utf-8
import time
import pymssql
import pandas as pd

def insert_data_to_sql(df, server, database, username, password, table_name,mode='Overlay'):
    # 連接到數(shù)據(jù)庫(kù)
    conn = pymssql.connect(server=server, user=username, password=password, database=database)
    # 創(chuàng)建游標(biāo)對(duì)象
    cursor = conn.cursor()
    # 獲取 DataFrame 對(duì)象的字段名和數(shù)據(jù)類(lèi)型
    columns = list(df.columns)
    dtypes = df.dtypes
    if mode=='Overlay':
        try:
        #覆蓋模式
            cursor.execute("DROP TABLE {}".format(table_name))
        except:
            print('表不存在，直接創(chuàng)建……')
        # 構(gòu)造創(chuàng)建表的 SQL 語(yǔ)句
        create_table_sql = f'CREATE TABLE [{table_name}] ('
        for col_name, col_type in zip(columns, dtypes):
            if col_type == 'int64':
                create_table_sql += f'[{col_name}] BIGINT,'
            elif col_type == 'float64':
                create_table_sql += f'[{col_name}] FLOAT,'
            elif col_type== 'datetime64[ns]' or '時(shí)間' in col_name or '日期' in col_name:
                create_table_sql += f'[{col_name}] DATETIME2(0),'
            elif col_type == 'date':
                create_table_sql += f'[{col_name}] DATE,'
            else:
                create_table_sql += f'[{col_name}] NVARCHAR(max),'
        create_table_sql = create_table_sql.rstrip(',') + ');'
        cursor.execute(create_table_sql)
    # 將 DataFrame 轉(zhuǎn)換成元組列表
    data = [tuple(row) for row in df.fillna(0).values.tolist()]
    # 構(gòu)造插入數(shù)據(jù)的 SQL 語(yǔ)句
    insert_sql = f'INSERT INTO [{table_name}] ('
    insert_sql += ','.join([f'[{col_name}]' for col_name in columns]) + ') VALUES ('
    insert_sql += ','.join(['%s'] * len(columns)) + ');'

    # 將數(shù)據(jù)插入到數(shù)據(jù)庫(kù)
    cursor.executemany(insert_sql, data)
    # 提交事務(wù)
    conn.commit()
    # 關(guān)閉數(shù)據(jù)庫(kù)連接
    conn.close()
   # 數(shù)據(jù)庫(kù)連接參數(shù)