先利用pip安装pymssql库
pip install pymssql
具体连接、测试代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# server默认为127.0.0.1，如果打开了tcp动态端口的需要加上端口号，如'127.0.0.1:1433'
# user默认为sa
# password为自己设置的密码
# database为数据库名字
server = '127.0.0.1'
user = "sa"
password = "123456"
database = "pubs"
conn = pymssql.connect(server, user, password, database)
# 可简化为conn = pymssql.connect(host='localhost', user='sa', password='123456', database='pubs')
cursor = conn.cursor()
cursor.execute('select * from titles')
print( cursor.fetchall() )
# 如果用pandas读取数据库
import pymssql
import pandas as pd
conn = pymssql.connect('ip地址','账号','密码','数据库')
sql_1 = "select id,creat_time from 表名"
#利用pandas直接获取数据"
data = pd.read_sql(sql_1, conn)
conn.close()
print(data)
|
封装好的版本：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
#coding=utf-8
# sqlserver的连接
import pymssql
class mssql:
def __init__(self,host,user,pwd,db):
self.host = host
self.user = user
self.pwd = pwd
self.db = db
def __getconnect(self):
"""
得到连接信息
返回: conn.cursor()
"""
if not self.db:
raise(nameerror,"没有设置数据库信息")
self.conn = pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset="utf8")
cur = self.conn.cursor()
if not cur:
raise(nameerror,"连接数据库失败")
else:
return cur
def execquery(self,sql):
"""
执行查询语句
返回的是一个包含tuple的list，list的元素是记录行，tuple的元素是每行记录的字段
"""
cur = self.__getconnect()
cur.execute(sql)
reslist = cur.fetchall()
#查询完毕后必须关闭连接
self.conn.close()
return reslist
def execnonquery(self,sql):
"""
执行非查询语句
调用示例：
cur = self.__getconnect()
cur.execute(sql)
self.conn.commit()
self.conn.close()
"""
cur = self.__getconnect()
cur.execute(sql)
self.conn.commit()
self.conn.close()
def main():
# host默认为127.0.0.1，如果打开了tcp动态端口的需要加上端口号，如'127.0.0.1:1433'
# user默认为sa
# pwd为自己设置的密码
# db为数据库名字
ms = mssql(host='127.0.0.1',user="sa",pwd="123456",db="pubs")
reslist = ms.execquery("select * from titles")
print(reslist)
if __name__ == '__main__':
main()
|
如果出现pymssql.operationalerror: (20009, b'db-lib error message 20009, severity 9:\nunable to connect: adaptive server is unavailable or does not exist (szs\sqlexpress)\n')类似保错，有以下几个可能的原因：
1.数据库名字写错
2.tcp/ip协议未开启，这个位于（右键此电脑，点击管理，点击服务与应用程序，点击sql配置管理器，点击sql server网络配置，点击mssqlserver的协议，右键tcp/ip，点击启用，重启电脑后才会生效）
3.动态端口错误，默认是没有打开动态端口的，如果打开了就需要写端口号，在2中的tcp/ip协议中查看动态端口号，点击tcp/ip协议，点击ip地址，然后翻到最下面，找到ipall 里面的动态端口号，也可以将动态端口号删掉，然后不写
4.sa用户登录未启用
打开sql server management studio，点击安全性，点击登录名，如果sa项出现红色的×则说明sa用户登录未启用，右键sa点击属性，点击状态即可启用。
到此这篇关于教你怎么用python连接sql server的文章就介绍到这了,更多相关python连接sql server内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/qq_45801299/article/details/116762358