python连接并简单操作SQLserver数据库

实验环境&＃xff1a;

python版本3.9

Python 3.9.7 (tags/v3.9.7:1016ef3, Aug 30 2021, 20:19:38) [MSC v.1929 64 bit (AMD64)] on win32
Type "help", "copyright", "credits" or "license" for more information.
>>>


SQLserver版本2019

exec xp_msver


基本步骤&＃xff1a;

安装pymssql模块

#pip 安装pymssql (python3.6以上直接安装不上)
pip install pymssql


#在官网下载pymssql对应版本&＃xff0c;在当前文件夹下
https://pypi.org/project/pymssql/
pip install pymssql-2.2.4-cp39-cp39-win_amd64.whl


编写代码

sqlserver.py

#coding&＃061;utf-8 #settng设置全局为utf—8格式
#导包
import pymssql
#创建连接字符串 &＃xff08;sqlserver默认端口为1433&＃xff09;
conn &＃061;pymssql.connect(host&＃061;&＃039;localhost&＃039;, #这里的host&＃061;&＃039;_&＃039;可以用本机ip或ip&＃043;端口号
server&＃061;"******",#本地服务器
port&＃061;"1433",#TCP端口
user&＃061;"sa",password&＃061;"******",
database&＃061;"******",
charset&＃061;"GBK"
#这里设置全局的GBK&＃xff0c;如果设置的是UTF—8需要将数据库默认的GBK转化成UTF-8
)
if conn:
print(&＃039;连接数据库成功!&＃039;)#测试是否连接上


查询

#查询语句
cursor &＃061;conn.cursor() #使用cursor()方法获取操作游标
sql_select&＃061;"SELECT * FROM STUDENT" #数据库查询语句
cursor.execute(sql_select) #执行语句
results &＃061;cursor.fetchall() #获取所有记录列表
#print(&＃039;原始:&＃039;,end&＃061;"")
#print(result) #后边有空格
for result in results:
result&＃061; list(result) #元组转化为列表
for res in range (len(result)):
if isinstance(result[res],str):
result[res]&＃061;result[res].replace(&＃039; &＃039;,&＃039;&＃039;)解决空格问题
result&＃061;tuple(result) #列表再转换为元组
print("处理后&＃xff1a;",end&＃061;"")
print(result)
#
conn.commit()
#关闭数据库
conn.close()


原始&＃xff1a;

处理后&＃xff1a;

插入

#插入语句
cursor &＃061;conn.cursor()
sql_insert&＃061;"insert into student values(990031,&＃039;wang&＃039;,20,&＃039;男&＃039;,&＃039;bb&＃039;,&＃039;aa&＃039;)"
cursor.execute(sql_insert)
conn.commit()
conn.close()


更新

#更新语句
cursor &＃061;conn.cursor()
sql_update&＃061;"update student set AGE&＃061;21 where SNO&＃061;&＃039;990031&＃039; "
cursor.execute(sql_update)
conn.commit()
conn.close()


删除语句

#删除语句
cursor &＃061;conn.cursor()
sql_delete&＃061;"delete from student where sno&＃061;&＃039;990031&＃039;"
cursor.execute(sql_delete)
conn.commit()
conn.close()


增加表

#新建表
cursor &＃061;conn.cursor()
sql_create&＃061;"""create table table_student(SNO int primary key not null,SNAME varchar(100),SDEPT varchar(100),BPLACE varchar(100))"""
cursor.execute(sql_create)
conn.commit()
conn.close()


错误1&＃xff1a;

报错

原因

没有把TCP/IP协议打开

查看TCP端口位置&＃xff1a;

保证TCP/IP开启&＃xff1a;

开启之后&＃xff0c;服务&＃xff0c;重新启动服务

错误2&＃xff1a;

出现查询结果乱码&＃xff1a;

解决办法&＃xff1a;

查看sqlserver的编码&＃xff1a;

select COLLATIONPROPERTY(&＃039;chinese_PRC_Stroke_CI_AI_KS_WS&＃039;,&＃039;CodePage&＃039;)


查询结果&＃xff1a;

936 简体中文gbk

950 繁体中文BIG5

437 加拿大/美国 英语

932 日文

949 韩文

866 俄文

来源：鲨鱼啵啵霸