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

      

  • 相关阅读:
    c数据结构 顺序表和链表 相关操作
    查找字符串中是否存在指定的字符
    比较两人生日相差多少天
    十进制转化为二进制(栈算法)
    c数据结构栈的基本操作(字符逆序输出)
    Django笔记-登陆、注册(利用cookie实现)
    Django笔记-常见错误整理
    Django笔记-post与get方法相关出错记录
    Django笔记-登陆注册-1
    Django笔记-helloworld
  • 原文地址:https://www.cnblogs.com/ezplusy/p/7773444.html
Copyright © 2011-2022 走看看