python 连接 SQL Server 数据库（使用 pymssql 库）

import pymssql

host = \'127.0.0.1\'
user = \'sa\'
password = \'******\'
database = \'WMS\'


# 数据库连接
def db_connect():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database)
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # 使用 execute（）方法执行 SQL 查询
    cursor.execute(\'select @@version\')
    # 使用 fetchone（）方法获取单条数据
    data = cursor.fetchone()
    print(f\'Database version: {data[0]}\')
    # 关闭数据库连接，此时自动关闭多有游标对象
    db.close()


# 创建数据库表
def create_table():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database)
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # 使用 execute（）方法执行 SQL，如果表存在就删除
    cursor.execute(\'drop table if exists teacher\')
    # 使用预处理语句创建表
    sql = \'\'\'create table teacher(
        id int primary key,
        name varchar(20) not null,
        sex varchar(2) not null,
        age int not null)\'\'\'
    try:
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print(\'CREATE TABLE SUCCESS.\')
    # 捕获与数据库相关的错误
    except pymssql.Error as err:
        print(f\'CREATE TABLE FAILED, CASE:{err}\')
        # 如果发生错误就回滚
        db.rollback()
    finally:
        # 关闭数据库连接
        db.close()


# 删除数据库表
def drop_table():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database)
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # 使用预处理语句删除表
    sql = \'drop table teacher\'
    try:
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print(\'DROP TABLE SUCCESS.\')
    # 捕获与数据库相关的错误
    except pymssql.Error as err:
        print(f\'DROP TABLE FAILED, CASE:{err}\')
        # 如果发生错误就回滚
        db.rollback()
    finally:
        # 关闭数据库连接
        db.close()


# 数据库插入
def insert_record():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database)
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # SQL 插入语句
    sql = "insert information values(1001, \'小明\', \'男\', 18)"
    try:
        # 执行 SQL 语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print(\'INSERT SUCCESS.\')
    # 捕获与数据库相关的错误
    except pymssql.Error as err:
        print(f\'INSERT FAILED, CASE:{err}\')
        # 如果发生错误就回滚
        db.rollback()
    finally:
        # 关闭数据库连接
        db.close()


# 数据库删除
def delete_record():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database)
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # SQL 删除语句
    sql = "delete from information where sex=\'女\'"
    try:
        # 执行 SQL 语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print(\'DELETE SUCCESS.\')
    # 捕获与数据库相关的错误
    except pymssql.Error as err:
        print(f\'DELETE FAILED, CASE:{err}\')
        # 如果发生错误就回滚
        db.rollback()
    finally:
        # 关闭数据库连接
        db.close()


# 数据库更新
def update_record():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database)
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # SQL 更新语句
    sql = "update information set age=25 where name=\'小明\'"
    try:
        # 执行 SQL 语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print(\'UPDATE SUCCESS.\')
    # 捕获与数据库相关的错误
    except pymssql.Error as err:
        print(f\'UPDATE FAILED, CASE:{err}\')
        # 如果发生错误就回滚
        db.rollback()
    finally:
        # 关闭数据库连接
        db.close()


# 数据库查询
def query_record():
    # 打开数据库连接
    db = pymssql.connect(host, user, password, database, charset=\'utf8\')
    # 使用 cursor（）方法创建一个游标对象 cursor
    cursor = db.cursor()
    # SQL 查询语句
    sql = \'select * from information\'
    try:
        # 执行 SQL 语句
        cursor.execute(sql)
        \'\'\'
        fetchone()：该方法获取下一个查询结果集，结果集是一个对象。
        fetchall()：接收全部返回结果行。
        rowcount：返回执行 execute（）方法后影响的行数
        \'\'\'
        # 获取所有记录列表
        results = cursor.fetchall()
        for row in results:
            num = row[0]
            # 解决中文乱码问题
            name = row[1].encode(\'latin-1\').decode(\'gbk\')
            sex = row[2].encode(\'latin-1\').decode(\'gbk\')
            age = row[3]
            # 输出结果
            print(f\'id:{num}, name:{name}, sex:{sex}, age:{age}\')
    # 捕获与数据库相关的错误
    except pymssql.Error as err:
        print(f\'QUERY MySQL table FAILED, CASE:{err}\')
    finally:
        # 关闭数据库连接
        db.close()


if __name__ == \'__main__\':
    db_connect()