zoukankan      html  css  js  c++  java
  • python 3.6 链接mssql 进行数据操作

    #!/usr/bin/env python
    # -*- coding: UTF-8 -*-
    
    import pymssql
    
    
    class MSSQL(object):
        '''
        对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):
            '''
            得到链接信息
            :return: 
            '''
            if not self.db:
                raise (NameError,"没有设置数据库信息")
            self.connect=pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset="utf8")
            cur=self.connect.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
            :param sql: sql语句
            :return: 
            '''
            cur=self.GetConnect()
            cur.execute(sql)
            resList = cur.fetchall()
    
            #查询完毕后必须关闭连接
            self.connect.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.connect.commit()
            self.connect.close()
    
    def test():
            ## ms = MSSQL(host="localhost",user="sa",pwd="123456",db="PythonWeiboStatistics")
            ## #返回的是一个包含tuple的list,list的元素是记录行,tuple的元素是每行记录的字段
            ## ms.ExecNonQuery("insert into WeiBoUser values('2','3')")
    
            ms = MSSQL(host="localhost", user="zl", pwd="zl@123456", db="zhongla20170901")
            resList = ms.ExecQuery("SELECT * FROM Pub_Law")
            print(resList)
    
    
    if __name__ == '__main__':
        test()
    

      

  • 相关阅读:
    第五章 Python——字符编码与文件处理
    第六章 Python——函数与面向过程编程
    第七章 Python——模块与包
    第一章 计算机硬件基础与操作系统介绍
    luogu P1706 全排列问题
    luogu 2142 高精度减法
    luogu P1601 高精度加法
    luogu P1803 线段覆盖 贪心
    luogu P1031 均分纸牌 贪心
    luogu P2678 跳石头 二分答案
  • 原文地址:https://www.cnblogs.com/ezplusy/p/7773444.html
Copyright © 2011-2022 走看看