python 使用pymssql 连接M

发布时间：2019-08-27 08:03:41编辑：auto阅读（1525）

    知识点：如果连接数据库不使用默认端口，需要在连接host地址上加上端口

    如cacelbert01.mysql.alibabalabs.com:3306

    #coding=gbk

    ##############################################################
    # Copyright (C), 2009-2010, aliyun
    # FileName: dbunit.py
    # Author: elbert.chenh
    # Version: 0.1
    # History:
    # <Author/Maintainer> <Date> <Modification>
    # elbert.chenh 10/07/11 Create this file
    #############################################################
    import sys
    import ConfigParser
    import datetime,time
    import binascii
    import os
    import types
    import os
    import pdb
    import pymssql

    class DBUnit:
    def __init__(self,user=None,passwd=None,host=None,database=None):
    try:
    self.connection = pymssql.connect(host=host, user = user, password =passwd, database=database)
    self.cursor= self.connection.cursor()
    except:
    print "Could not connect to DB server."
    exit(0)




    def __del__(self):
    self.cursor.close()
    self.connection.close()

    def read(self,Sql,param=None):
    '''Exec select sql , return type is Tuple,use len fun return select row num
    use param like this:
    Sql=select * from table where param=%s and param1=%s
    param=(value1,valuei2)
    '''
    try:
    cursor = self.connection.cursor()
    if param==None:
    cursor.execute(Sql)
    rs = cursor.fetchall()
    cursor.close()
    else:
    cursor.execute(Sql,param)
    rs = cursor.fetchall()
    cursor.close()
    except Exception,e:
    print e
    rs = ()
    return rs

    def write(self,sql,param,iscommit=True):
    try:
    cursor = self.connection.cursor()
    print sql
    n = cursor.executemany(sql,param)
    if iscommit :
    self.connection.commit()
    return n
    except Exception,e:
    print e
    self.connection.rollback()
    return -1
    def writeOneRecord(self,sql):
    try:
    cursor = self.connection.cursor()
    n = cursor.execute(sql)
    self.connection.commit()
    return int(cursor.lastrowid)
    except:
    self.connection.rollback()
    return -1



    if __name__ == '__main__':
    a = time.time()
    db = DBUnit('accelbert08','a1234561','cacelbert01.mysql.alibabalabs.com:3306','elbert08') //不使用默认端口
    rs = db.read("select count(*) from t_file")
    print rs
    #db.delete(dictinu)

关键字：

上一篇： python 2.7后的字符串赋值

下一篇： Python在Linux下的Tab补齐（