python配置資料庫 python連線資料庫。

#-*- coding: utf-8 -*-

__author__ = 'hero'

importpymssqlimportxml.dom.minidomimportosimportsys

curpath= os.path.abspath(os.path.dirname(__file__))

rootpath=os.path.split(curpath)[0]

configtype_retest= 'retest'configtype_ping= 'ping'configtype_agetest= 'agetest'configtype_ipx= 'ipx'

###載入資料庫連線資料

defloaddbconfig(self,dbtype):

xmldoc= xml.dom.minidom.parse(os.getcwd() +'\\conf\\/dbconfig.xml'#此處路徑為配置檔案的路徑root=xmldoc.documentelement

sql_element=root.getelementsbytagname(dbtype)[0]returnsql_elementdef __exchangedatabydbconnection(self):

sqlinfo= self.loaddbconfig('mssql')

db_host= sqlinfo.getelementsbytagname('host')[0].firstchild.data

db_database= sqlinfo.getelementsbytagname('database')[0].firstchild.data

db_user= sqlinfo.getelementsbytagname('username')[0].firstchild.data

db_pwd= sqlinfo.getelementsbytagname('password')[0].firstchild.data

conn= pymssql.connect(user=db_user,password=db_pwd,database=db_database,host=db_host)

conn.autocommit(true)returnconn###讀取資料###

defgetdatabysql(self,sqlstr):try:

conn= self.__exchangedatabydbconnection()if notconn:raise(nameerror,'資料庫連線失敗')else:

cur=conn.cursor()

cur.execute(sqlstr)

reslist=cur.fetchall()

conn.close()returnreslistexceptexception,e:print(e)raise(nameerror,'資料庫操作失敗')###更改資料庫###

defsetdatabysql(self,sqlstr):try:

conn= self.__exchangedatabydbconnection()if notconn:raise(nameerror,'資料庫連線失敗')returnfalseelse:

cur=conn.cursor()

cur.execute(sqlstr)

conn.commit()

conn.close()returntrueexceptexception,e:print(e)raise(nameerror,'資料庫操作失敗')returnfalseif __name__ == '__main__':

pn= 'byaux-ctn0003'sqlstr= "select * from producttype where productno = '"+pn+"'"edata=exchangedata()

reslist= edata.getdatabysql(sqlstr=sqlstr)for datarow inreslist:print(datarow[0])