Pymssql使用

麻煩的是,，經(jīng)常安裝失敗,。需要先下載包,，再在本地進(jìn)行安裝。

pip install pymssql

傳送門：https://www.lfd./~gohlke/pythonlibs/#pymssql

可根據(jù)自己Python的版本來(lái)下載,，之前安裝Python3.7使用有些問(wèn)題

安裝pymssql:

pymssql對(duì)數(shù)據(jù)庫(kù)的一些操作：

import pymssql
# server    數(shù)據(jù)庫(kù)服務(wù)器名稱或IP
# user      用戶名
# password  密碼
# database  數(shù)據(jù)庫(kù)名稱
server = "*******"
user = "sa"
password = "*******"
database = "Python"
conn = pymssql.connect(server, user, password, database)
cursor = conn.cursor()
# 新建表
def CreateTable():
    sql = """
    IF OBJECT_ID('persons', 'U') IS NOT NULL DROP TABLE persons
    CREATE TABLE persons (id INT NOT NULL identity(1,1),name VARCHAR(100),age int,PRIMARY KEY(id))
    """
    cursor.execute(sql)
    conn.commit()
# 批量插入數(shù)據(jù)
def InsertData():
    sql = "INSERT INTO persons(name,age) VALUES (%s, %d)"
    data = [
        ('zhangsan', 15),
        ('lisi', 16),
        ('wangwu T.', 17)]
    cursor.executemany(sql, data)
    # 如果沒(méi)有指定autocommit屬性為True的話就需要調(diào)用commit()方法
    conn.commit()
# 刪除操作
def DeleteData():
    sql = "delete persons where id=5"
    cursor.execute(sql)
    conn.commit()
# 查詢操作
def SelectTable():
    sql = "SELECT * FROM persons"
    cursor.execute(sql)
    row = cursor.fetchone()
    while row:
        print("ID=%d, Name=%s" % (row[0], row[1]))
        row = cursor.fetchone()
    # 也可以使用for循環(huán)來(lái)迭代查詢結(jié)果
    # for row in cursor:
    #     print("ID=%d, Name=%s" % (row[0], row[1]))
# 修改操作
def UpdateData():
    sql = "update [persons] set name ='Python1' where id<3"
    cursor.execute(sql)
    conn.commit()
def main():
    # CreateTable()
    InsertData()
    DeleteData()
    UpdateData()
    SelectTable()
    conn.close()
if __name__ == '__main__':
    main()
# 關(guān)閉連接

  mssql_helper：

import pymssql
class MSSQL:
    def __init__(self,host,user,pwd,db): #類的構(gòu)造函數(shù)，初始化數(shù)據(jù)庫(kù)連接ip或者域名，以及用戶名,，密碼，要連接的數(shù)據(jù)庫(kù)名稱
        self.host=host
        self.user=user
        self.pwd=pwd
        self.db=db
    def __GetConnect(self):  #得到數(shù)據(jù)庫(kù)連接信息函數(shù),， 返回: conn.cursor()
        self.conn=pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset='utf8')
        cur=self.conn.cursor()  #將數(shù)據(jù)庫(kù)連接信息,，賦值給cur。
        if not cur:
            return(NameError,"連接數(shù)據(jù)庫(kù)失敗")
        else:
            return cur
    #執(zhí)行查詢語(yǔ)句,返回的是一個(gè)包含tuple的list,，list的元素是記錄行,，tuple的元素是每行記錄的字段
    def ExecQuery(self,sql):  #執(zhí)行Sql語(yǔ)句函數(shù)，返回結(jié)果
        cur = self.__GetConnect()   #獲得數(shù)據(jù)庫(kù)連接信息
        cur.execute(sql)  #執(zhí)行Sql語(yǔ)句
        resList = cur.fetchall()  #獲得所有的查詢結(jié)果
        #查詢完畢后必須關(guān)閉連接
        self.conn.close()   #返回查詢結(jié)果
        return resList
    def ExecNonQuery(self,sql):
        cur = self.__GetConnect()
        cur.execute(sql)
        self.conn.commit()
        self.conn.close()

使用：

import mssql_helper
server = "********"
user = "sa"
password = "*********"
database = "Python"
mssql =""
def main():
    global mssql
    mssql = mssql_helper.MSSQL(server,user,password,database)
def test():
    rows = mssql.ExecQuery("SELECT * FROM persons")    
    print(rows)
if __name__ == '__main__':
    main()
    test()