python 使用pymssql 连接MSSQL数据库(带端口)
2011-10-26 11:32
1461 查看
知识点:如果连接数据库不使用默认端口,需要在连接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)
如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 使用pymssql 连接MSSQL数据库(带端口)
- python 利用pymssql连接MSSQL数据库,简单示例
- Python 3.6 连接mssql数据库(pymssql 方式)
- MSSQL数据库修改端口如何使用客户端连接
- Python连接SQL Server数据库 - pymssql使用基础
- Python连接mssql数据库编码问题解决方法
- python使用mysqldb连接数据库操作方法示例详解
- 使用JDBC连接MSSQL数据库中2000/2005/2008的区别
- docker(7):使用python 连接数据库,插入并查询数据--link
- 第二个程序:用pymssql连接mssql数据库
- MSSQL数据库允许外网连接的端口设置问题
- 关于使用JDBC方式连接MSSQL数据库
- python使用mysqldb连接数据库操作方法示例详解
- 一次使用Python连接数据库生成二维码并安装为windows服务的工作任务
- 使用Python连接postgresql数据库
- python pymssql连接MSSQL以及无法连接解决方法
- Python 连接Oracle 数据库,需要使用cx_Oracle 包
- Python连接mysql数据库及python使用mysqldb连接数据库教程
- python 使用pymssql连接sql server数据库
- python 使用pymssql连接sql server数据库