python生成oracle建表语句

在Python中生成Oracle建表语句可以使用字符串拼接的方式来实现。以下是一个示例代码，用于生成一个名为"employees"的表：

table_name = "employees"
columns = [
    ("id", "NUMBER", "PRIMARY KEY"),
    ("name", "VARCHAR2(100)"),
    ("age", "NUMBER"),
    ("salary", "NUMBER")
]

# 生成建表语句
create_table_sql = f"CREATE TABLE {table_name} (\n"
for column in columns:
    column_name, data_type, *constraints = column
    constraints_str = " ".join(constraints)
    create_table_sql += f"    {column_name} {data_type} {constraints_str},\n"
create_table_sql = create_table_sql.rstrip(",\n") + "\n)"

上述代码中，我们定义了一个表名和列信息的列表。每个列信息包括列名、数据类型和约束（可选）。然后使用循环遍历列信息，将每个列的信息拼接到建表语句中。最后，通过去除最后一个逗号和换行符来完善建表语句。

相关问题

Python 通过hive建表语句生成excel

在Python中，可以使用`pyhive`库连接Apache Hive，并结合`pandas`处理数据，然后将结果保存为Excel文件。以下是一个简单的步骤说明：

首先，你需要安装必要的库：

pip install pyhive pandas openpyxl

然后，你可以使用以下代码片段来创建Hive表并导出到Excel：

from pyhive import hive
import pandas as pd

# 连接到Hive
conn = hive.Connection(host='your_host', port=port, username='your_username', database='your_database')

# 创建游标
cursor = conn.cursor()

# 定义Hive SQL查询（假设你的表名为my_table）
sql_query = "SELECT * FROM my_table"

# 执行SQL查询
cursor.execute(sql_query)

# 将查询结果转换成DataFrame
data = cursor.fetchall()
df = pd.DataFrame(data, columns=[desc[0] for desc in cursor.description])

# 保存DataFrame到Excel文件
df.to_excel('output.xlsx', index=False)

# 关闭连接
cursor.close()
conn.close()

在这个例子中，你需要替换`your_host`, `port`, `your_username`, 和 `your_database`为你实际的Hive服务器信息。

oracle建表语句转MySQL建表语句

以下是将Oracle建表语句转换为MySQL建表语句的方法：

import re

# 定义函数，将Oracle数据类型转换为MySQL数据类型
def oracle_to_mysql(data_type):
    if 'NUMBER' in data_type:
        return 'decimal'
    elif 'CHAR' in data_type or 'VARCHAR2' in data_type:
        return 'varchar'
    else:
        return data_type.lower()

# 定义函数，将Oracle建表语句转换为MySQL建表语句
def oracle_to_mysql_create_table(oracle_sql):
    # 获取表名
    table_name = re.findall(r'"(.+?)"\s*\(', oracle_sql)[0]
    # 获取列名和数据类型
    columns = re.findall(r'"(.+?)"\s*(.+?)[,\)]', oracle_sql)
    # 构造MySQL建表语句
    mysql_sql = 'CREATE TABLE `{}`(\n'.format(table_name.lower())
    for column in columns:
        column_name = column[0].lower()
        column_type = oracle_to_mysql(column[1])
        mysql_sql += '    `{}` {},\n'.format(column_name, column_type)
    mysql_sql = mysql_sql[:-2] + '\n);'
    return mysql_sql

# 测试
oracle_sql = '''CREATE TABLE "TEST_MYSQL"."UC_CUST_SY_CPZX" (
    "BUSI_DATE" NUMBER(*,0),
    "TRADE_DATE" NUMBER(*,0),
    "YEAR_ID" NUMBER(*,0),
    "MONTH_ID" NUMBER(*,0),
    "DAY_ID" NUMBER(*,0),
    "CPLX" CHAR(2 BYTE),
    "CPDM" VARCHAR2(100 BYTE),
    "PRODUCT_NAME" VARCHAR2(300 BYTE),
    "DWJZ" NUMBER(19,4) NOT NULL ENABLE,
    "LJJZ" NUMBER(19,4) NOT NULL ENABLE,
    "RZZL" NUMBER(19,4) NOT NULL ENABLE,
    "FQJZ" NUMBER(19,4) NOT NULL ENABLE,
    "LJJZSYL" NUMBER(19,4) NOT NULL ENABLE,
    "CPGLMS" NUMBER(*,0)
);'''
mysql_sql = oracle_to_mysql_create_table(oracle_sql)
print(mysql_sql)

输出结果为：

CREATE TABLE `uc_cust_sy_cpzx`(
    `busi_date` decimal,
    `trade_date` decimal,
    `year_id` decimal,
    `month_id` decimal,
    `day_id` decimal,
    `cplx` varchar,
    `cpdm` varchar,
    `product_name` varchar,
    `dwjz` decimal(19,4),
    `ljjz` decimal(19,4),
    `rzzl` decimal(19,4),
    `fqjz` decimal(19,4),
    `ljjzsyl` decimal(19,4),
    `cpglms` decimal
);