<output id="qn6qe"></output>

    1. <output id="qn6qe"><tt id="qn6qe"></tt></output>
    2. <strike id="qn6qe"></strike>

      亚洲 日本 欧洲 欧美 视频,日韩中文字幕有码av,一本一道av中文字幕无码,国产线播放免费人成视频播放,人妻少妇偷人无码视频,日夜啪啪一区二区三区,国产尤物精品自在拍视频首页,久热这里只有精品12

      Python導出DB2數據庫的表結構(使用SSH隧道)

      1、安裝依賴

      pip install sshtunnel pyodbc  openpyxl  pandas 

      2、安裝 DB2 ODBC 驅動?

      我使用的DB2版本是10.5,下載的ODBC驅動文件如下:

      ibm_data_server_driver_package_win64_v10.5.exe

      3、完整代碼

      import pandas as pd
      import pyodbc
      from openpyxl import load_workbook
      from openpyxl.styles import Border, Side, PatternFill, Font, Alignment
      from openpyxl.utils import get_column_letter
      from sshtunnel import SSHTunnelForwarder
      
      
      def apply_formatting(excel_path):
          """應用格式設置"""
          wb = load_workbook(excel_path)
      
          # 定義樣式
          blue_fill = PatternFill(
              start_color="0070C0",
              end_color="0070C0",
              fill_type="solid"
          )
          thin_border = Border(
              left=Side(style='thin'),
              right=Side(style='thin'),
              top=Side(style='thin'),
              bottom=Side(style='thin')
          )
      
          for sheet in wb.worksheets:
              # 設置標題行樣式
              for cell in sheet[1]:
                  cell.fill = blue_fill
                  cell.font = Font(color="FFFFFF", bold=True)
      
              # 設置邊框
              for row in sheet.iter_rows(min_row=1):
                  for cell in row:
                      cell.border = thin_border
      
              # 自適應列寬
              for column in sheet.columns:
                  max_length = max(
                      len(str(cell.value)) for cell in column
                  )
                  adjusted_width = (max_length + 2) * 1.2
                  sheet.column_dimensions[
                      get_column_letter(column[0].column)
                  ].width = adjusted_width
      
              # 定義居中對齊樣式(水平居中 + 垂直居中)
              alignment = Alignment(
                  horizontal='center',  # 水平居中:'left', 'center', 'right', 'justify'
                  vertical='center'  # 垂直居中:'top', 'center', 'bottom'
              )
              # 對指定的列設置居中
              columns_to_center = ['A', 'H']     # 將A列和H列設置居中
              for col in columns_to_center:
                  for cell in sheet[col]:
                      cell.alignment = alignment
      
          wb.save(excel_path)
      
      
      def add_hyperlinks(excel_path):
          """添加雙向超鏈接"""
          wb = load_workbook(excel_path)
          ws_summary = wb["首頁總覽"]
      
          # 總覽表到分表
          for row in ws_summary.iter_rows(min_row=2):
              table_name = row[1].value
              sheet_name = table_name[:30]
              hyperlink = f"#'{sheet_name}'!A1"
              row[1].hyperlink = hyperlink
              row[1].style = "Hyperlink"
      
          # 分表到總覽表
          for sheet_name in wb.sheetnames[1:]:
              ws = wb[sheet_name]
              last_row = ws.max_row + 1
              ws.cell(row=last_row, column=1, value="返回\"首頁總覽\"")
              ws.cell(row=last_row, column=1).hyperlink = "#'首頁總覽'!A1"
              ws.cell(row=last_row, column=1).style = "Hyperlink"
      
          wb.save(excel_path)
      
      
      def sql_to_dataframe(cursor):
          """將 pyodbc cursor 結果轉換為 DataFrame"""
          # 獲取列名
          columns = [column[0] for column in cursor.description]
          # 獲取數據并創建DataFrame
          data = cursor.fetchall()
          return pd.DataFrame.from_records(data, columns=columns)
      
      
      def get_tables_info(cursor, db_user):
          """獲取所有表信息"""
          query = f"""
                  SELECT 
                      TABNAME  AS  table_name,
                       REMARKS AS  table_comment
                  FROM SYSCAT.TABLES 
                  WHERE  TYPE = 'T'  AND TABSCHEMA = '{db_user}'
                  ORDER BY TABNAME
          """
          # 執行查詢
          cursor.execute(query)
          return sql_to_dataframe(cursor)
      
      
      def get_columns_info(cursor, table_name):
          """獲取指定表結構詳情"""
          query = f"""
                  SELECT
                      T.TABNAME  AS table_name,
                      C.COLNAME  AS column_name,
                      C.REMARKS   AS column_comment,
                      C.TYPENAME  AS column_type,
                      C.LENGTH    AS  type_length,
                      NULLIF(C.SCALE,0)   AS  type_scale,
                      CASE 
                          WHEN C.NULLS = 'N' THEN '[√]' 
                          ELSE '[]' 
                      END              AS  isnotnull
                  FROM
                      SYSCAT.TABLES T
                  JOIN
                      SYSCAT.COLUMNS C
                      ON T.TABSCHEMA = C.TABSCHEMA 
                      AND T.TABNAME = C.TABNAME
                  WHERE
                      T.TYPE = 'T' 
                      AND T.TABSCHEMA NOT IN ('SYSIBM', 'SYSCAT', 'SYSSTAT')  
                     AND T.TABNAME = '{table_name}' 
                  ORDER BY
                      T.TABNAME,
                      C.COLNO;  
          """
      
          # 執行查詢
          cursor.execute(query)
          return sql_to_dataframe(cursor)
      
      
      if __name__ == '__main__':
      
          # ================== 配置信息 ==================
          # SSH 隧道配置
          ssh_host = "100.100.20.20"  # SSH跳板機IP
          ssh_port = 22               # SSH端口(默認22)
          ssh_user = "root"           # SSH用戶名
          ssh_password = "Root@1234"  # SSH密碼
      
          # DB2數據庫參數
          db_host = "100.100.10.10"  # 數據庫服務器實際IP(SSH隧道目標)
          db_port = 50000           # DB2 默認端口
          db_name = "MYDB"          # DB2 數據庫
          db_user = "db2user"       # DB2 用戶
          db_password = "DB2@user"  # DB2 密碼
      
          # 本地綁定端口(隨機可用端口)
          local_bind_port = 9090
      
          # ================== 建立SSH隧道 ==================
          try:
              with SSHTunnelForwarder(
                      (ssh_host, ssh_port),
                      ssh_username=ssh_user,
                      ssh_password=ssh_password,
                      remote_bind_address=(db_host, db_port),
                      local_bind_address=("0.0.0.0", local_bind_port),
                      set_keepalive=15         # 保持連接活躍
              ) as tunnel:
                  local_bind_port2 = tunnel.local_bind_port
                  print(f"SSH隧道建立成功,本地端口:{local_bind_port2}")
      
                  # ================== 連接數據庫 ==================
                  # 方法一:使用 pyodbc
                  # 連接字符串(注意使用本地端口)
                  conn_str = (
                      "DRIVER={IBM DB2 ODBC DRIVER};"  # 驅動名稱需與ODBC配置一致
                      f"DATABASE={db_name};"
                      "HOSTNAME=localhost;"
                      f"PORT={local_bind_port2};"
                      "PROTOCOL=TCPIP;"
                      f"UID={db_user};"
                      f"PWD={db_password};"
                  )
                  conn = pyodbc.connect(conn_str)
                  cursor = conn.cursor()
                  print("數據庫連接成功!")
      
                  # 獲取所有表的信息
                  df_summary = get_tables_info(cursor, db_user.upper())
                  df_summary.insert(0, '序號', range(1, len(df_summary) + 1))
      
                  # 寫入的Excel名稱
                  output_file = f"數據庫{db_name}表結構.xlsx"
      
                  # 創建Excel寫入對象
                  with pd.ExcelWriter(output_file, engine='openpyxl') as writer:
                      # 寫入總覽頁
                      df_summary.to_excel(
                          writer,
                          sheet_name='首頁總覽',
                          index=False,
                          header=['序號', '表名', '表注釋']
                      )
      
                      # 遍歷寫入各表結構
                      for _, row in df_summary.iterrows():
                          table_name = row['TABLE_NAME']
      
                          print("正在導出表", table_name, "的表結構")
      
                          df_columns = get_columns_info(cursor, table_name)
                          df_columns.insert(0, '序號', range(1, len(df_columns) + 1))
                          df_columns.to_excel(
                              writer,
                              sheet_name=table_name[:30],  # Excel表名最長31字符
                              index=False,
                              header=["序號", "表名", "字段名稱", "字段注釋", "字段類型", "長度", "標度", "非空"]
                          )
      
                  # 應用格式和超鏈接
                  print("正在設置超鏈接和邊框......")
                  add_hyperlinks(output_file)    # 設置超鏈接
                  apply_formatting(output_file)   # 設置邊框
      
                  print(f"表結構已成功導出至 {output_file}")
      
          except Exception as e:
              print(f"連接失敗: {str(e)}")
          finally:
              if 'conn' in locals():
                  conn.close()

       

      posted @ 2025-05-20 16:20  業余磚家  閱讀(30)  評論(0)    收藏  舉報
      主站蜘蛛池模板: 国产午夜亚洲精品不卡网站| 偷拍美女厕所尿尿嘘嘘小便| 国产精品白浆免费视频| 免费高潮了好湿h视频| 国产精品自拍午夜福利| 日韩一区二区三区一级片| 在线免费不卡视频| 天堂V亚洲国产V第一次| 国产精品亚洲片夜色在线| 夜爽8888视频在线观看| 性色在线视频精品| 白嫩少妇bbw撒尿视频| 国产成人精品一区二区不卡| 在线a亚洲老鸭窝天堂| 亚洲中文字幕日产无码成人片| 欧美寡妇xxxx黑人猛交| 又粗又硬又黄a级毛片| 亚欧洲乱码视频在线专区| 国产短视频精品一区二区| 免费无码黄网站在线观看| 广元市| 亚洲av精选一区二区| 国产精品视频亚洲二区| 国产精品久久久久7777按摩| 日本无码欧美一区精品久久| 涟源市| 国产av中文字幕精品| 亚洲欧美偷国产日韩| 国产乱人激情H在线观看| 国产国产久热这里只有精品| 成人欧美日韩一区二区三区| 男人一天堂精品国产乱码| 阿巴嘎旗| 免费又大粗又爽又黄少妇毛片| 国产一区二区三区美女| 国产+亚洲+制服| 欧美日韩国产图片区一区| 成年女人免费v片| 亚洲精品一区二区五月天| 久久精品娱乐亚洲领先| 成人无码潮喷在线观看|