mysql oracle python实现连接方法
admin
2023-05-07 23:02:19
0

下文主要给大家带来mysql oracle python实现连接方法,希望这些内容能够带给大家实际用处,这也是我编辑mysql oracle python实现连接方法这篇文章的主要目的。好了,废话不多说,大家直接看下文吧。

#encoding:utf-8

#dataProc

#auth xiajikun

import sys

# oracle库连接模块

import cx_Oracle

# mysql库连接

import MySQLdb

import time

import os


#水电煤库

# SDM = 'username/password@ip:port/servicename'

DB_ORA_STR = 'admin/123456@10.1.1.2:1521/c9db1111'


# oracle连接

class OracleLogin(object):

    #初始化,创建连接数据库对象  

    def __init__(self, loginName):

        #--建立连接

        self.conn = cx_Oracle.connect(loginName)

        #--获取游标        

        self.cursor = self.conn.cursor()

        self.l_v_status = self.cursor.var(cx_Oracle.NUMBER)

        self.l_v_return_code = self.cursor.var(cx_Oracle.STRING)

        self.l_v_sno = self.cursor.var(cx_Oracle.STRING)

    #查询sql方法

    def selectSql(self, sql):

        self.cursor.execute(sql)

        self.result_sql = self.cursor.fetchall()

        self.count = self.cursor.rowcount

        self.conn.commit()

    #执行sql方法

    def execSql(self,sql):

        self.cursor.execute(sql)

        self.conn.commit()

    #执行存储过程方法

    def getMetaData(self,procdName, sql, procArgs):

        self.procResult = self.cursor.callproc(procdName, procArgs)

        self.cursor.execute(sql)

        self.result_pro = self.cursor.fetchall()

        self.count = self.cursor.rowcount

        self.conn.commit()

    #无用时自动析构此对象

    def __del__(self):

        self.cursor.close()

        self.conn.close()


# mysql连接

class MysqlLogin(object):

    #初始化,自动连接数据库

    def __init__(self, db_str):

        # self.conn = MySQLdb.connect(host='10.7.11.242',user='credcard',passwd='5sFVDVCeKo',db='credcard',port=3320)

        self.conn = MySQLdb.connect(host=db_str[0],user=db_str[1],passwd=db_str[2],db=db_str[3],port=db_str[4])


        #self.conn = MySQLdb.connect('%s' % db_str)

        #self.conn = MySQLdb.connect('%s,%s,%s,%s,%d' % (db_str)

        self.cur = self.conn.cursor()

    def exec_sql(self, sql):

        self.cur.execute(sql)

        self.conn.commit()

    def select_sql(self, sql):

        self.cur.execute(sql)

        self.tmpdata = self.cur.fetchall()

    #自动断开游标和连接

    def __del__(self):

        self.cur.close()

        self.conn.close()


db_str = ('10.1.1.1','username','123456','db_name',3306)

db_obj = MysqlLogin(db_str)

sql = 'select * from tabname limit 10'

db_obj.select_sql(sql)

print db_obj.tmpdata

对于以上关于mysql oracle python实现连接方法,大家是不是觉得非常有帮助。如果需要了解更多内容,请继续关注我们的行业资讯,相信你会喜欢上这些内容的。

上一篇:数据库优化

下一篇:什么是子查询

相关内容

热门资讯

“点热成电”,挖掘能源金矿 “十五五”规划纲要提出,深入实施能源安全新战略,加快构建清洁低碳安全高效的新型能源体系,建设能源强国...
新能源车企激战大电量时代 “量... 时报财经图库/供图 证券时报记者 叶玲珍 作为车企角逐的主战场,电池容量军备竞赛日趋白热化。中国汽车...
以方透露内塔尼亚胡曾秘访阿联酋... 以色列方面5月13日透露,以总理内塔尼亚胡在以色列对伊朗发动大规模军事行动期间曾秘密访问阿联酋,并称...
英伟达、谷歌、苹果均创市值历史... 【CNMO科技消息】5月14日,CNMO科技注意到,美东时间周三,美股三大指数涨跌不一,纳指和标普5...
商业化探索持续深入 “AI+教... 来源:滚动播报 (来源:经济参考报) 人工智能通识课堂上,教师发出指令几分钟后,学生手绘的卡通人物就...
偷拍男子是否会被清出公务员拟录... 近日,南京审计大学一名在校研究生顾某某因涉嫌偷拍女生隐私,引发关注。顾某某已被国家税务总局江苏省税务...
乌克兰首都基辅传出爆炸声 △乌克兰首都基辅(资料图)当地时间14日,乌克兰首都基辅传出爆炸声,此前基辅拉响防空警报。(总台记者...
移动空调制冷一会就停止了 原因可能是空调正在开启启动模式,移动空调存在逐步启动模式,在空调开启过程中会逐步启动保证空调的正常运...
排水管怎么安装 首先需关闭上水阀,然后将软管用扳手拧下来装上三通,注意需要按一个内部带丝扣的一面,然后在三通上接上原...
净水器滤芯正确顺序图 以常规的欧吉分五级过滤瓶为例,前三级是初次过滤,主要是PP棉、颗粒活性炭、块状活性炭、树脂等。通常组...