第一步---新建DMSQL.py文件，python封裝DM8--- import dmPython class MyDM():def __init__(self, user, password,server,port,): #類的構(gòu)造函數(shù)，初始化self.user = user #用戶名self.password = password #密碼self.server = server #服務(wù)地址self.port = port??????????#端口號(hào)#執(zhí)行數(shù)據(jù)庫連接def get_con(self):try:conn = dmPython.connect(user=self.user, password=self.password, server=self.server, port=self.port, autoCommit=True)return connexcept:print('dmPython Error:%s')#執(zhí)行查詢語句def ExecQuery(self, sql):try:con = self.get_con() #連接數(shù)據(jù)庫cur = con.cursor() #將數(shù)據(jù)庫連接信息賦給curcur.execute(sql) # 執(zhí)行sql語句fc = cur.fetchall() # 獲得所有的查詢結(jié)果return fc #返回查詢結(jié)果except:print('dmPython Error') #查詢不到報(bào)錯(cuò)finally:con.close() #查詢完畢后關(guān)閉連接#執(zhí)行非查詢語句def ExecNonQuery(self,sql):"""執(zhí)行非查詢語句cur = self.__GetConnect()cur.execute(sql)self.conn.commit()self.conn.close()"""try:con = self.get_con()cur = con.cursor()except :print("error")cur.execute(sql)con.commit()con.close()if __name__ == "__main__":db = MyDM( server='127.0.0.1', port=5236, user='SYSDBA', password='123456789')# insert_by_param()# select_by_where()# delete_by_where()# select_all()# update_by_where()#delete_nowhere() ---------------------------------------------------------------------------------------第二步---同目錄下新建DMSQL.txt文件，內(nèi)容如下--- YELLOW #用戶名 123456789 #密碼 127.0.0.1 #IP地址 5236 #端口號(hào)---------------------------------------------------------------------------------------

第三步---新建一個(gè)publicFA.py文件，調(diào)用MyDM類，連接DM數(shù)據(jù)庫---

from DMSQL import MyDMdef get_DMsql(): # 達(dá)夢(mèng)庫r = []with open('DMSQL.txt', 'r') as f:for line in f:r.append(list(line.strip('\n').split(','))[0])DMsql = MyDM(user="%s" % r[0], password="%s" %r[1], server="%s" % r[2], port="%s" % r[3])return DMsql

---------------------------------------------------------------------------------------------------------------------------------

第四步---進(jìn)行數(shù)據(jù)庫增刪改查--- from publicFA import get_DMsql#調(diào)用函數(shù)DMsql=get_DMsql()#連接達(dá)夢(mèng)數(shù)據(jù)庫 result=DMsql.ExecQuery("select * from INI_PIII ")#查詢語句 #------------非查詢語句(增、刪、改) result=DMsql.ExecNonQuery("delete from INI_PIII where STCD=40104360") result=DMsql.ExecNonQuery("insert into INI_PIII(STCD,ID,CV,CS,X,HIDE) VALUES(40104360,9,9,9,9,9)") result=DMsql.ExecNonQuery("update INI_PIII set HIDE=1 where STCD=40104360")

注：查詢和非查詢語句如何不帶模式名，見該專欄下《python操作達(dá)夢(mèng)數(shù)據(jù)庫，怎么寫SQL如何才能不帶上模式名？》

總結(jié)

以上是生活随笔為你收集整理的python封装DM达梦数据库-增删改查的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。