python 连接mssqlserver方法之pymssql

安装pymssql模块，参照我之前写的博文python中使用第三方模块

import sys
import pymssql
class Mssql:def <a href="http://so.21ops.com/cse/search?s=9181936462520079739&entry=1&q=__init" class="bdcs-inlinelink" target="_blank">__init</a>__(self, <a href="http://so.21ops.com/cse/search?s=9181936462520079739&entry=1&q=config" class="bdcs-inlinelink" target="_blank">config</a>):self.cf = configdef __Connect(self):try:self.conn = pymssql.connect(host=self.cf['host'],user=self.cf['user'],password=self.cf['<a href="http://so.21ops.com/cse/search?s=9181936462520079739&entry=1&q=pwd" class="bdcs-inlinelink" target="_blank">pwd</a>'],database=self.cf['db'])cur = self.conn.cursor()except Exception, err:print "Error decoding config file: %s" % str(err)sys.exit(1)return curdef select(self, sql):try:cur = self.__Connect()cur.execute(sql)rows = cur.fetchall()cur.close()self.conn.close()return rowsexcept Exception, err:print "Error decoding config file: %s" % str(err)sys.exit(1)def insert(self, sql):try:cur = self.__Connect()cur.execute(sql)cur.close()self.conn.commit()self.conn.close()except Exception, err:print "Error decoding config file: %s" % str(err)sys.exit(1)
def main():config = {'host':'test_db','user':'test','pwd':'123456','db':'Testdb'}mssql = Mssql(config)#select sqlsql = "select * from test_table"rows = mssql.select(sql)#insert sqlsql = "insert into test_table values('1','2','3')"mssql.insert(sql)
if __name__ == "__main__":main()

注：host里test_db是调用freetds配置里的，可以直接写ip

下面是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()

游标跳转到下一个数据集

#查询操作

with closing(pymssql.connect(host='.',user='sa',password='123456',database='gamedatas')) as conn :

cur = conn.cursor()

#SELECT 长连接查询操作（逐条方式获取数据）

sql = "select * from user"

cur.execute(sql)

for i in range(cur.rowcount):

print cur.fetchone()

#SELECT 短链接查询操作（一次查询将所有数据取出）

sql = "select * from user"

cur.execute(sql)

print cur.fetchall()

#INSERT

sql = "INSERT INTO user(name)VAlUES(%s)"

uuidstr = str(uuid.uuid1())

cur.execute(sql,(uuidstr,))

conn.commit()

print cur._result

#Update

vl = '张三'

sql = 'update name set title = %s where id=1'

cur.execute(sql,(vl,))

conn.commit()

#参数化查询

sql = "select * from pcontent where id=%d"

cur.execute(sql,(1,))

print cur.fetchall()

# 调用存储过程SP_GetALLContent 无参数

sql = "Exec SP_GetALLContent"

cur.execute(sql)

print cur.fetchall()

# 调用存储过程SP_GetContentByID 有参数的

sql = "Exec SP_GetContentByID %d"

cur.execute(sql,(3,))

print cur.fetchall()

python 连接mssqlserver方法之pymssql相关推荐

python连接SQL Server：Pymssql模块
数据库版本:SQL Server 2012. 按照python版本来选择下载pymssql模块,这样才能连接上sql server. 我安装的python版本是3.5 ,64位的,所以下载的pymss ...
Python连接SQL Server数据库 - pymssql使用基础
连接数据库 pymssql连接数据库的方式和使用sqlite的方式基本相同: 使用connect创建连接对象 connect.cursor创建游标对象,SQL语句的执行基本都在游标上进行 cursor ...
python连接SQL Server取多个结果集：Pymssql模块
基本的用法可以参考:python连接SQL Server:Pymssql模块和上一篇文章中的代码,只取一个结果集不同,这次会一次运行2个sql语句,然后分别取出2个结果集,打印输出. 代码中有详细的 ...
Python 连接FTP服务器并实现文件夹下载实例演示，python区分ftp目录下文件和文件夹方法，ftp目录下包含中文名问题处理
Python 连接 FTP 服务器并实现文件夹下载实例演示第一章:连接 FTP 服务器并实现文件夹下载 ① 连接 FTP 服务器 ② 进入指定目录并显示文件信息 ③ 区分文件和文件夹名 ④ 文件夹名 ...
Python连接Greenplum及常用gp函数和方法（持续更新）
前言了解postgresql Python连接gp 记录postgresql一些函数和方法(持续更新) ①:int类型时间转time类型时间 ②:合并两列值 ③:取最近N个月数据 ④:按指定字符串或 ...
Python 技术篇-连接oracle数据库并执行sql语句实例演示，python连接oracle数据库oci详细配置方法
Python 连接 Oracle 数据库第一章:连接 oracle 数据与环境配置 ① 连接 oracle 数据库效果演示 ② oci 下载 ③ oci 配置 ④ 环境变量配置 ⑤ 检测是否有 or ...
python连接redis哨兵_Python redis.sentinel方法代码示例
本文整理汇总了Python中redis.sentinel方法的典型用法代码示例.如果您正苦于以下问题:Python redis.sentinel方法的具体用法?Python redis.sentine ...
python连接sql server
python连接sql server 先利用pip安装pymssql库 pip install pymssql 具体连接.测试代码: # server默认为127.0.0.1,如果打开了TCP动态端口 ...
python 连接sql server
linux 下pymssql模块的安装所需压缩包: pymssql-2.1.0.tar.bz2 freetds-patched.tar.gz 安装: tar -xvf pymssql-2.1.0.t ...

python 连接mssqlserver方法之pymssql

python 连接mssqlserver方法之pymssql相关推荐

最新文章

热门文章