python 使用pymssql连接sql server数据库

本文涉及的产品
云数据库 RDS SQL Server,独享型 2核4GB
简介:

Python连接SQL Server数据库 - pymssql使用基础   

----原文地址:http://www.cnblogs.com/baiyangcao/p/pymssql_basic.html


下面是pymssql里参数使用说明,如下:

  1. pymssqlCnx类(用于连接Mssql数据库)

pymssql.connect()来初始化连接类,它允许如下的参数。

dsn:连接字符串,主要用于与之前版本的pymssql兼容
user:用户名
password:密码
trusted:布尔值,指定是否使用windows身份认证登陆
host :主机名
database:数据库
timeout:查询超时
login_timeout:登陆超时
charset:数据库的字符集
as_dict:布尔值,指定返回值是字典还是元组
max_conn:最大连接数


2. Method

autocommit(status)

布尔值,指示是否自动提交事务,默认的状态是关闭的,如果打开,你必须调用commit()方法来提交事务。


close()

关闭连接


cursor()
返回游标对象,用于查询和返回数据
commit()

提交事务。


rollback()
回滚事务

pymssqlCursor类
用于从数据库查询和返回数据

rowcount

返回最后操作影响的行数。


connection

返回创建游标的连接对象


lastrowid
返回插入的最后一行

rownumber
返回当前数据集中的游标(通过索引)


3. 游标方法

close()
关闭游标

execute(operation)

执行操作


execute(operation, params)

执行操作,可以提供参数进行相应操作


executemany(operation, params_seq)

执行操作,Params_seq为元组

fetchone()
在结果中读取下一行

fetchmany(size=None)
在结果中读取指定数目的行


fetchall()
读取所有行

nextset()
游标跳转到下一个数据集



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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
#coding=utf-8 
#!/usr/bin/env python
#-------------------------------------------------------------------------------
# Name: pymssqlTest.py
# Purpose: 测试 pymssql库,该库到这里下载:http://www.lfd.uci.edu/~gohlke/pythonlibs/#pymssql
#
# Author: scott
#
# Created: 04/02/2012
#-------------------------------------------------------------------------------
 
import  pymssql
 
 
class  MSSQL:
     """
     对pymssql的简单封装
     pymssql库,该库到这里下载:http://www.lfd.uci.edu/~gohlke/pythonlibs/#pymssql
     使用该库时,需要在Sql Server Configuration Manager里面将TCP/IP协议开启
 
     用法:
 
     """
 
     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的元素是每行记录的字段
 
         调用示例:
                 ms = MSSQL(host="localhost",user="sa",pwd="123456",db="PythonWeiboStatistics")
                 resList = ms.ExecQuery("SELECT id,NickName FROM WeiBoUser")
                 for (id,NickName) in resList:
                     print str(id),NickName
         """
         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():
## ms = MSSQL(host="localhost",user="sa",pwd="123456",db="PythonWeiboStatistics")
## #返回的是一个包含tuple的list,list的元素是记录行,tuple的元素是每行记录的字段
## ms.ExecNonQuery("insert into WeiBoUser values('2','3')")
 
     ms  =  MSSQL(host = "localhost" ,user = "sa" ,pwd = "123456" ,db = "PythonWeiboStatistics" )
     resList  =  ms.ExecQuery( "SELECT id,weibocontent FROM WeiBo" )
     for  ( id ,weibocontent)  in  resList:
         print  str (weibocontent).decode( "utf8" )
 
if  __name__  = =  '__main__' :
     main()


注意事项:

    使用pymssql进行中文操作时候可能会出现中文乱码,我解决的方案是:

  • 文件头加上 #coding=utf8

  • sql语句中有中文的时候进行encode

       insertSql = "insert into WeiBo([UserId],[WeiBoContent],[PublishDate]) values(1,'测试','2012/2/1')".encode("utf8")

  •  连接的时候加入charset设置信息

        pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset="utf8")


相关实践学习
使用SQL语句管理索引
本次实验主要介绍如何在RDS-SQLServer数据库中,使用SQL语句管理索引。
SQL Server on Linux入门教程
SQL Server数据库一直只提供Windows下的版本。2016年微软宣布推出可运行在Linux系统下的SQL Server数据库,该版本目前还是早期预览版本。本课程主要介绍SQLServer On Linux的基本知识。 相关的阿里云产品:云数据库RDS SQL Server版 RDS SQL Server不仅拥有高可用架构和任意时间点的数据恢复功能,强力支撑各种企业应用,同时也包含了微软的License费用,减少额外支出。 了解产品详情: https://www.aliyun.com/product/rds/sqlserver
相关文章
|
17天前
|
缓存 NoSQL 关系型数据库
在Python Web开发过程中:数据库与缓存,MySQL和NoSQL数据库的主要差异是什么?
MySQL是关系型DB,依赖预定义的表格结构,适合结构化数据和复杂查询,但扩展性有限。NoSQL提供灵活的非结构化数据存储(如JSON),无统一查询语言,但能横向扩展,适用于大规模、高并发场景。选择取决于应用需求和扩展策略。
110 1
|
23天前
|
SQL 关系型数据库 MySQL
阿里云MySQL数据库价格、购买、创建账号密码和连接数据库教程
阿里云数据库使用指南:购买MySQL、SQL Server等RDS实例,选择配置和地区,完成支付。创建数据库和账号,设置权限。通过DMS登录数据库,使用账号密码访问。同地域VPC内的ECS需将IP加入白名单以实现内网连接。参考链接提供详细步骤。
363 3
|
2天前
|
SQL 关系型数据库 数据库
Python中SQLite数据库操作详解:利用sqlite3模块
【4月更文挑战第13天】在Python编程中,SQLite数据库是一个轻量级的关系型数据库管理系统,它包含在一个单一的文件内,不需要一个单独的服务器进程或操作系统级别的配置。由于其简单易用和高效性,SQLite经常作为应用程序的本地数据库解决方案。Python的内置sqlite3模块提供了与SQLite数据库交互的接口,使得在Python中操作SQLite数据库变得非常容易。
|
3天前
|
SQL 监控 关系型数据库
PG数据库释放闲置连接
PG数据库释放闲置连接
6 0
|
13天前
|
弹性计算 关系型数据库 MySQL
阿里云数据库服务器价格表,数据库创建、连接和使用教程
阿里云数据库使用流程包括购买和管理。选择所需数据库类型如MySQL,完成实名认证后购买,配置CPU、内存和存储。确保数据库地域与ECS相同以允许内网连接。创建数据库和账号,设置权限。通过DMS登录数据库,使用账号密码连接。同一VPC内的ECS需添加至白名单以进行内网通信。参考官方文档进行详细操作。
70 3
|
14天前
|
网络协议 数据库连接 网络安全
DM数据库连接数据库时报:创建sokect连接失败
DM数据库连接数据库时报:创建sokect连接失败
12 0
|
25天前
|
SQL Java 关系型数据库
在Python中编写Java数据库驱动是不可能的
在Python中编写Java数据库驱动是不可能的
|
5月前
|
SQL Oracle 关系型数据库
本机不安装Oracle客户端,使用PL/SQL Developer连接远程数据库
本机不安装Oracle客户端,使用PL/SQL Developer连接远程数据库
134 0
|
SQL 程序员 数据库
【python】连接sql server数据库,并实现简单的增删改查(1)
Python编程语言越来越受到大家的喜爱,本篇文章就从链接微软数据库进行增删改查操作的讲解
517 0
|
3月前
|
SQL 关系型数据库 数据库连接
Python 连接 SQL 数据库 -pyodbc
以下是如何在 Python 中使用 pyodbc 连接到 SQL 数据库的基本步骤和详解
43 0