python访问MsSql

╰+攻爆jí腚メ 2022-07-15 06:58 148阅读 0赞

python访问MsSql
    
    一、安装pymssql模块：
    pip install pymssql
    
    具体下载pymssql模块，可以从http://www.lfd.uci.edu/~gohlke/pythonlibs/#pymssql找到：
    
    二、pymssqlCnx类 和 pymssqlCursor类及游标方法
    1.pymssqlCnx类：用于连接Mssql数据库
    你可以使用pymssql.connect()来初始化连接类。它允许如下的参数。
    dsn：连接字符串，主要用于与之前版本的pymssql兼容
    user：用户名
    password：密码
    trusted：布尔值,指定是否使用windows身份认证登陆
    host :主机名
    database：数据库
    timeout：查询超时
    login_timeout：登陆超时
    charset：数据库的字符集
    as_dict：布尔值,指定返回值是字典还是元组
    max_conn：最大连接数
    
    方法：
    autocommit(status)
    布尔值,指示是否自动提交事务，默认的状态是关闭的，如果打开，你必须调用commit()方法来提交事务。
    
    close()
    关闭连接
    
    cursor()
    返回游标对象，用于查询和返回数据
    
    commit()
    提交事务。
    
    rollback()
    回滚事务
    
    
    2.pymssqlCursor类：用于从数据库查询和返回数据
    
    rowcount
    返回最后操作影响的行数。
    
    connection
    返回创建游标的连接对象
    
    lastrowid
    返回插入的最后一行
    
    rownumber
    返回当前数据集中的游标（通过索引）
    
    3.游标方法
    close()
    关闭游标
    
    execute(operation)
    执行操作
    
    execute(operation, params)
    执行操作，可以提供参数进行相应操作
    
    executemany(operation, params_seq)
    执行操作，Params_seq为元组
    
    fetchone()
    在结果中读取下一行
    
    fetchmany(size=None)
    在结果中读取指定数目的行
    
    fetchall()
    读取所有行
    
    nextset()
    游标跳转到下一个数据集
    
    __iter__(),next()
    These methods faciliatePython iterator protocol. You most likely will not call them directly, but indirectly by using iterators.
    setinputsizes(),setoutputsize()
    These methods do nothing, as permitted by DB-API specs.
    
    三、举例Demo
    示例：返回当前数据库时间
    import os,pymssql
    
    server="192.168.0.28"
    user="sa"
    password="123123"
    
    conn=pymssql.connect(server,user,password,database="master")
    cursor=conn.cursor()
    cursor.execute("""select getdate()""")
    row=cursor.fetchone()
    while row:
        print("sqlserver datetime:%s"%(row[0]))
        row=cursor.fetchone()
    
    conn.close()
    
    
    示例:
    #-*-coding:gb2312-*-
    import pymssql
    #数据库连接
    conn = pymssql.connect(host =".",database ="master",user="sa",password="123123")
    #定义游标
    cur = conn.cursor()
    #执行指定的sql
    cur.execute("select * from dbo.bookshop")
    #游标读取第一行
    row = cur.fetchone()
    for i in range(2):
       if i ==2:
           print row[0]," ".ljust(10-len(row[0])," "),row[1]," ".ljust(20-len(row[1])," "),row[2]
       row = cur.fetchone()
    
    #关闭数据库连接
    conn.close()
    
    四、sql封装包
    封装包一
    注意：读取数据的时候需要decode('utf-8')，写数据的时候需要encode('utf-8')，这样就可以避免烦人的中文乱码或报错问题。
    如果还提示编码问题，检查文件保存的编码是否为utf8格式。
    
    # -*- coding:utf-8 -*-
    import pymssql
    class MSSQL:
        def __init__(self,host,user,pwd,db):
            self.host = host
            self.user = user
            self.pwd = pwd
            self.db = db
    
        def __GetConnect(self):
            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):
            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()
    
    #调用
    ms = MSSQL(host="192.168.0.28",user="sa",pwd="123123",db="testdb")
    reslist = ms.ExecQuery("select * from webuser")
    for i in reslist:
        print(i)
    
    newsql="update webuser set name='%s' where id=1"%u'测试'
    print newsql
    ms.ExecNonQuery(newsql.encode('utf-8'))
    
    
    封装包二：似乎第一个封装更通用一些。
    import sys
    import pymssql
    class Mssql:
        def __init__(self, config):
            self.cf = config
        def __Connect(self):
            try:
                self.conn = pymssql.connect(host=self.cf['host'],user=self.cf['user'],password=self.cf['pwd'],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)
    
        #查询
        sql = "select * from test_table"
        rows = mssql.select(sql)
        #插入
        sql = "insert into test_table values('1','2','3')"
        mssql.insert(sql)
    if __name__ == "__main__":
        main()