godba

admin

这是一个Python脚本，使用cx_Oracle模块连接Oracle数据库，并从一个数据库中的表获取连接信息，然后遍历这些连接信息并连接到对应的数据库，查询其中的用户信息，最后将查询结果插入到另一个数据库中的表中。该脚本的作用是将多个Oracle数据库的用户信息收集到一个统一的库中，方便管理和监控。

具体来说，该脚本会执行以下步骤：

使用cx_Oracle模块连接到一个Oracle数据库，从其中的godba_add_db表获取多个目标数据库的连接信息，包括IP地址、监听端口、服务名、用户名、密码和数据库UUID等。

遍历连接信息，对于每个目标数据库，使用cx_Oracle模块连接到该数据库，查询其中的dba_users表，获取其中的用户信息，包括用户名、用户ID、密码、账号状态、锁定时间、过期时间、默认表空间、临时表空间、本地临时表空间、创建时间、配置文件、初始资源消费者组、外部名称、密码版本、启用版本、身份验证类型、仅代理连接、常用设置、上次登录、Oracle维护、继承、默认排序规则、隐式用户、全局分片、密码更改时间和检查时间等。

将查询结果插入到另一个Oracle数据库的godba_users表中，也包括上述所有字段，以及db_uuid字段，用于标识该用户信息所属的数据库。

关闭游标和连接，并提交事务。

1. import cx_Oracle
   
2. 
   
3. #从rep库获取数据库连接信息
   
4. target_conn = cx_Oracle.connect("zhyu/zhyu@192.168.56.101:1521/ora19")
   
5. target_cursor = target_conn.cursor()
   
6. dbl_query = "SELECT IP_ADDRESS, LISTENER_PORT, SERVICE_NAME, USERNAME, PASSWORD, DB_UUID FROM godba_add_db"
   
7. target_cursor.execute(dbl_query)
   
8. #遍历连接信息，从源库查询信息并存放到rep库
   
9. for IP_ADDRESS, LISTENER_PORT, SERVICE_NAME, USERNAME, PASSWORD, DB_UUID in target_cursor.fetchall():
   
10.   source_conn = cx_Oracle.connect(f"{USERNAME}/{PASSWORD}@{IP_ADDRESS}:{LISTENER_PORT}/{SERVICE_NAME}")
    
11.   source_cursor = source_conn.cursor()
    
12.   source_cursor.execute("SELECT username,user_id,password,account_status,lock_date,expiry_date,default_tablespace,temporary_tablespace,local_temp_tablespace,created,profile,INITIAL_RSRC_CONSUMER_GROUP,EXTERNAL_NAME,PASSWORD_VERSIONS,EDITIONS_ENABLED,AUTHENTICATION_TYPE,PROXY_ONLY_CONNECT,COMMON,LAST_LOGIN,ORACLE_MAINTAINED,INHERITED,DEFAULT_COLLATION,IMPLICIT,ALL_SHARD,PASSWORD_CHANGE_DATE,to_char(sysdate,'yyyymmddhh24miss') check_time FROM dba_users")
    
13.   for result in source_cursor.fetchall():
    
14.     target_cursor.execute("INSERT INTO godba_users (username,user_id,password,account_status,lock_date,expiry_date,default_tablespace,temporary_tablespace,local_temp_tablespace,created,profile,INITIAL_RSRC_CONSUMER_GROUP,EXTERNAL_NAME,PASSWORD_VERSIONS,EDITIONS_ENABLED,AUTHENTICATION_TYPE,PROXY_ONLY_CONNECT,COMMON,LAST_LOGIN,ORACLE_MAINTAINED,INHERITED,DEFAULT_COLLATION,IMPLICIT,ALL_SHARD,PASSWORD_CHANGE_DATE,check_time,db_uuid) VALUES (:1, :2, :3, :4, :5, :6, :7, :8, :9, :10, :11, :12, :13, :14, :15, :16, :17, :18, :19, :20, :21, :22, :23, :24, :25, :26, :27)", result + (DB_UUID,))
    
15. #关闭游标，关闭连接
    
16.   source_cursor.close()
    
17.   source_conn.close()
    
18.   target_conn.commit()
    
19.   target_cursor.close()
    
20.   target_conn.close()

复制代码

admin

1. import cx_Oracle
   
2. import logging
   
3. import time
   
4. 
   
5. # 配置日志记录器
   
6. logger = logging.getLogger(__name__)
   
7. logger.setLevel(logging.INFO)
   
8. handler = logging.FileHandler("database.log")
   
9. handler.setLevel(logging.INFO)
   
10. formatter = logging.Formatter("%(asctime)s - %(levelname)s - %(message)s")
    
11. handler.setFormatter(formatter)
    
12. logger.addHandler(handler)
    
13. 
    
14. # 从rep库获取数据库连接信息
    
15. target_conn = cx_Oracle.connect("zhyu/zhyu@192.168.56.101:1521/ora19")
    
16. target_cursor = target_conn.cursor()
    
17. dbl_query = "SELECT IP_ADDRESS, LISTENER_PORT, SERVICE_NAME, USERNAME, PASSWORD, DB_UUID FROM godba_add_db"
    
18. target_cursor.execute(dbl_query)
    
19. 
    
20. # 遍历连接信息，从源库查询信息并存放到rep库
    
21. for IP_ADDRESS, LISTENER_PORT, SERVICE_NAME, USERNAME, PASSWORD, DB_UUID in target_cursor.fetchall():
    
22.     retry_count = 0
    
23.     while retry_count < 3:
    
24.         try:
    
25.             logger.info(f"Connecting to {IP_ADDRESS}:{LISTENER_PORT}/{SERVICE_NAME}...")
    
26.             source_conn = cx_Oracle.connect(
    
27.                 f"{USERNAME}/{PASSWORD}@{IP_ADDRESS}:{LISTENER_PORT}/{SERVICE_NAME}")
    
28.             source_cursor = source_conn.cursor()
    
29.             source_cursor.execute(
    
30.                 "SELECT username,user_id,password,account_status,lock_date,expiry_date,default_tablespace,temporary_tablespace,local_temp_tablespace,created,profile,INITIAL_RSRC_CONSUMER_GROUP,EXTERNAL_NAME,PASSWORD_VERSIONS,EDITIONS_ENABLED,AUTHENTICATION_TYPE,PROXY_ONLY_CONNECT,COMMON,LAST_LOGIN,ORACLE_MAINTAINED,INHERITED,DEFAULT_COLLATION,IMPLICIT,ALL_SHARD,PASSWORD_CHANGE_DATE,to_char(sysdate,'yyyymmddhh24miss') check_time FROM dba_users")
    
31.             for result in source_cursor.fetchall():
    
32.                 target_cursor.execute("INSERT INTO godba_users (username,user_id,password,account_status,lock_date,expiry_date,default_tablespace,temporary_tablespace,local_temp_tablespace,created,profile,INITIAL_RSRC_CONSUMER_GROUP,EXTERNAL_NAME,PASSWORD_VERSIONS,EDITIONS_ENABLED,AUTHENTICATION_TYPE,PROXY_ONLY_CONNECT,COMMON,LAST_LOGIN,ORACLE_MAINTAINED,INHERITED,DEFAULT_COLLATION,IMPLICIT,ALL_SHARD,PASSWORD_CHANGE_DATE,check_time,db_uuid) VALUES (:1, :2, :3, :4, :5, :6, :7, :8, :9, :10, :11, :12, :13, :14, :15, :16, :17, :18, :19, :20, :21, :22, :23, :24, :25, :26, :27)",
    
33.                                       result + (DB_UUID,))
    
34.             logger.info(f"Successfully processed {IP_ADDRESS}:{LISTENER_PORT}/{SERVICE_NAME}.")
    
35.             break
    
36.         except cx_Oracle.DatabaseError as e:
    
37.             logger.error(f"Unable to connect to {IP_ADDRESS}:{LISTENER_PORT}/{SERVICE_NAME}. Retry count: {retry_count+1}", exc_info=True)
    
38.             if retry_count == 2:
    
39.                 logger.error(f"Connection failed after 3 retries. Skipping to the next database.")
    
40.             else:
    
41.                 retry_count += 1
    
42.                 time.sleep(5)  # Wait for 5 seconds before retrying
    
43. 
    
44.     # 关闭游标，关闭连接
    
45.     source_cursor.close()
    
46.     source_conn.close()
    
47. 
    
48. target_conn.commit()
    
49. target_cursor.close()
    
50. target_conn.close()
    

复制代码

在上述代码中，我们使用了try-except块来捕获cx_Oracle.DatabaseError异常，该异常表示数据库连接失败。如果连接失败，将打印错误消息，并在重试次数小于3时进行重试。如果连续尝试3次都无法连接成功，则跳过当前数据库，继续下一个数据库的处理。
请注意，我在连接失败后添加了一个5秒的延迟，以避免频繁尝试连接导致过多的资源消耗。你可以根据实际情况调整这个延迟时间。
另外，我还将提交事务的操作移动到了循环外部，在处理完所有数据库后进行提交，以提高效率。