Python连接Oracle实例

select t.* from all_objects t where t.object_name = upper(&table_name);

 1 #!/usr/bin/env python
 2 #-*- coding:utf-8 -*-
 3 
 4 import cx_Oracle
 5 
 6 #username
 7 dbusernamea = ‘username1‘
 8 dbusernameb = ‘username2‘
 9 
10 #dbconnectaddress
11 db_usernamea = cx_Oracle.connect(dbusernamea,‘password‘,‘dbaddress‘)
12 db_usernameb = cx_Oracle.connect(dbusernameb,‘password‘,‘dbaddress‘)
13 
14 #cursor
15 cur_usernamea = db_usernamea.cursor()
16 cur_usernameb = db_usernameb.cursor()
17 
18 #readtablename
19 def ReadTableName():
20     fo = open("tablename.txt","r"):
21     print(‘open success!‘)
22     table_name = []
23     for i in fo.readlines():
24         if i != ‘\n‘ and i != ‘\r\n‘:
25             spiliti = i.replace(‘\t‘,‘‘).strip()
26             table_name.append(spiliti)
27     fo.close()
28     return table_name
29 
30 #
31 def CheckMainTable(ReadTableName):
32 
33     for tablename in ReadTableName:
34     sql_str_checkmaintable = """select a.* from all_objects a where a.object_name = upper(%s) """%tablename
35     cur_usernamrea.execute(sql_str_checkmaintable)
36     #获取结果集
37     rets = cur_usernamea.fetchall()
38     #如果结果集为空判断该表在A中不存在
39     if length(rets) == 0:
40         print(‘MainAcess don‘t have this table: ‘+tablename+‘\n‘)
41         #写入log writelines即可 如有需要
42         with open("filename_a","a") as a:
43             a.writelines.(tablename+‘\n‘)
44 
45     else:
46     　　sql_str_checksubtable = """select a.* from all_objects a where a.object_name = upper(%s) """%tablename
47     　　cur_usernamreb.execute(sql_str_checksubtable)
48     　　#获取结果集
49     　　recv = cur_usernameb.fetchall()
50     　　#如果结果集为空判断该表在B中不存在
51     　　if length(recv) == 0:
52         　　print(‘SubAcess don‘t have this table: ‘+tablename+‘\n‘)
53         　　#写入log writelines即可 如有需要
54　　　　　　　 with open("filename_b","a") as b:
55             　　b.writelines.(tablename+‘\n‘)
56 
57 if __name__ == ‘__main__‘:
58     CheckMainTable(ReadTableName())
59 
60 #关闭游标
61 db_usernamea.close()
62 db_usernameb.close()