python 连接mssqlserver方法之pymssql_pooleddb python 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 = config
    def __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 cur
                                                                                                                                                                                                                                                                                                                                                                                                 
    def select(self, sql):
        try:
            cur = self.__Connect()
            cur.execute(sql)
            rows = cur.fetchall()
            cur.close()
            self.conn.close()
            return rows
        except 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 sql
    sql = "select * from test_table"
    rows = mssql.select(sql)
    #insert sql
    sql = "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()