zoukankan      html  css  js  c++  java
  • python 使用pymssql连接sql server数据库(转)


    import pymssql


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

    def main():
    ## 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="sa",pwd="123456",db="PythonWeiboStatistics")
        resList = ms.ExecQuery("SELECT id,weibocontent FROM WeiBo")
        for (id,weibocontent) in resList:
            print str(weibocontent).decode("utf8")

    if __name__ == '__main__':
        main()
     
     
    注意事项:
        使用pymssql进行中文操作时候可能会出现中文乱码,我解决的方案是:
      • 文件头加上 #coding=utf8
      • sql语句中有中文的时候进行encode
           insertSql = "insert into WeiBo([UserId],[WeiBoContent],[PublishDate]) values(1,'测试','2012/2/1')".encode("utf8")
      •  连接的时候加入charset设置信息
            pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset="utf8")
  • 相关阅读:
    dubbo入门(一)
    java中文件操作《一》
    Unity 游戏框架搭建 2019 (七) 自定义快捷键
    凉鞋:我所理解的框架 【Unity 游戏框架搭建】
    Unity 游戏框架搭建 2019 (六) MenuItem 复用
    Unity 游戏框架搭建 2019 (五) 打开所在文件夹
    Unity 游戏框架搭建 2019 (四) 导出 UnityPackage
    Unity 游戏框架搭建 2019 (三) 生成文件名到剪切板
    Unity 游戏框架搭建 2019 (二) 文本复制到剪切板
    Unity 游戏框架搭建 2019 (一) 简介与第一个示例文件名的生成
  • 原文地址:https://www.cnblogs.com/seer/p/3209550.html
Copyright © 2011-2022 走看看