#coding=utf8

#!/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

import sys

import decimal

reload(sys)

sys.setdefaultencoding( "utf8" )

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()

總結

以上是生活随笔為你收集整理的pymssql mysql_Python利用pymssql访问mysql数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。