utils/tablesMetadata.py · halfh2o/Python_RESTfulAPI_Codegen

代码拉取完成,页面将自动刷新

扫描微信二维码支付

取消

支付完成

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 17

halfh2o/Python_RESTfulAPI_Codegen

forked from 华北电力大学-iDeal/Python_RESTfulAPI_Codegen

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

release

分支 (3)

标签 (5)

管理

release

master

dev

v2.0.0

v2.0.1

v1.0.0

v0.1.1

v0.1.0

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 3

标签 5

Python_RESTfulAPI_Codegen

utils

tablesMetadata.py

tablesMetadata.py 3.94 KB

#!/usr/bin/env python
# -*- coding:utf-8 -*-

# file:tablesMetadata.py.py
# author:Nathan
# datetime:2021年8月26日 14:56
# software: PyCharm

"""
 Get metadata of all tables
"""

from config.setting import Settings

class TableMetadata(object):

type_mapping = Settings.TYPE_MAPPING
 table_rule = Settings.TABLE_RULE
 database_type = Settings.DATABASE_TYPE

@classmethod
 def reload(cls):
 cls.type_mapping = Settings.TYPE_MAPPING
 cls.table_rule = Settings.TABLE_RULE
 cls.database_type = Settings.DATABASE_TYPE

@classmethod
 def get_tables_metadata(cls, metadata):
 # Get all tables object
 table_objs = metadata.tables.values()
 table_dict = {}

# Traverse each table object to get corresponding attributes to form an attribute dictionary
 for table in table_objs:
 # get the table name
 table_name = str(table)
 table_dict[table_name] = {}
 table_dict[table_name]['table_name'] = table_name
 table_dict[table_name]['is_logic_delete'] = False
 table_dict[table_name]['columns'] = {}
 table_dict[table_name]['foreign_keys'] = []
 table_dict[table_name]['business_key'] = {}

# Check record deletion method
 if table_name in cls.table_rule['table_record_delete_logic_way']:
 table_dict[table_name]['is_logic_delete'] = True

# Check if the business key exists
 if table_name in cls.table_rule['table_business_key_gen_rule']:
 business_key = table_dict[table_name]['business_key']
 business_key['column'], business_key['rule'] = tuple(cls.table_rule['table_business_key_gen_rule'][
 table_name].items())[0]

# 需要RSA加密的字段
 table_dict[table_name]['rsa_columns'] = []
 for key, value in Settings.RSA_TABLE_COLUMN.items():
 # 如果表名不匹配则进入下一轮循环
 if table_name != key:
 continue
 table_dict[table_name]['rsa_columns'] = value

# 初始化为空列表
 table_dict[table_name]['primaryKey'] = []

# Traverse each columns to get corresponding attributes
 for column in table.columns.values():
 table_dict[table_name]['columns'][str(column.name)] = {}
 table_dict[table_name]['columns'][str(column.name)]['name'] = str(column.name)

for type_ in cls.type_mapping:
 if cls.database_type != type_['database']:
 continue
 for python_type, sql_type_list in type_['data_map'].items():
 if str(column.type).lower() in sql_type_list:
 table_dict[table_name]['columns'][str(column.name)]['type'] = python_type
 break
 table_dict[table_name]['columns'][str(column.name)].setdefault('type', 'str')

if column.primary_key:
 table_dict[table_name]['primaryKey'].append(str(column.name))

# 是否自动递增
 table_dict[table_name]['columns'][str(column.name)][
 'is_autoincrement'] = True if column.autoincrement is True else False

if column.foreign_keys:
 # Traverse each foreign_key to get corresponding attributes
 for foreign_key in column.foreign_keys:
 table_dict[table_name]['foreign_keys'].append({
 'key': str(column.name),
 'target_table': str(foreign_key.column).split('.')[0],
 'target_key': str(foreign_key.column).split('.')[1]
 })

return table_dict

一键复制编辑原始数据按行查看历史

Nathan 提交于 2021年10月19日 21:17 +08:00 . 修复配置文件读取失败bug

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 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97

#!/usr/bin/env python
# -*- coding:utf-8 -*-

# file:tablesMetadata.py.py
# author:Nathan
# datetime:2021年8月26日 14:56
# software: PyCharm

"""
 Get metadata of all tables
"""


from config.setting import Settings


class TableMetadata(object):

 type_mapping = Settings.TYPE_MAPPING
 table_rule = Settings.TABLE_RULE
 database_type = Settings.DATABASE_TYPE

 @classmethod
 def reload(cls):
 cls.type_mapping = Settings.TYPE_MAPPING
 cls.table_rule = Settings.TABLE_RULE
 cls.database_type = Settings.DATABASE_TYPE

 @classmethod
 def get_tables_metadata(cls, metadata):
 # Get all tables object
 table_objs = metadata.tables.values()
 table_dict = {}

 # Traverse each table object to get corresponding attributes to form an attribute dictionary
 for table in table_objs:
 # get the table name
 table_name = str(table)
 table_dict[table_name] = {}
 table_dict[table_name]['table_name'] = table_name
 table_dict[table_name]['is_logic_delete'] = False
 table_dict[table_name]['columns'] = {}
 table_dict[table_name]['foreign_keys'] = []
 table_dict[table_name]['business_key'] = {}

 # Check record deletion method
 if table_name in cls.table_rule['table_record_delete_logic_way']:
 table_dict[table_name]['is_logic_delete'] = True

 # Check if the business key exists
 if table_name in cls.table_rule['table_business_key_gen_rule']:
 business_key = table_dict[table_name]['business_key']
 business_key['column'], business_key['rule'] = tuple(cls.table_rule['table_business_key_gen_rule'][
 table_name].items())[0]

 # 需要RSA加密的字段
 table_dict[table_name]['rsa_columns'] = []
 for key, value in Settings.RSA_TABLE_COLUMN.items():
 # 如果表名不匹配则进入下一轮循环
 if table_name != key:
 continue
 table_dict[table_name]['rsa_columns'] = value

 # 初始化为空列表
 table_dict[table_name]['primaryKey'] = []

 # Traverse each columns to get corresponding attributes
 for column in table.columns.values():
 table_dict[table_name]['columns'][str(column.name)] = {}
 table_dict[table_name]['columns'][str(column.name)]['name'] = str(column.name)

 for type_ in cls.type_mapping:
 if cls.database_type != type_['database']:
 continue
 for python_type, sql_type_list in type_['data_map'].items():
 if str(column.type).lower() in sql_type_list:
 table_dict[table_name]['columns'][str(column.name)]['type'] = python_type
 break
 table_dict[table_name]['columns'][str(column.name)].setdefault('type', 'str')

 if column.primary_key:
 table_dict[table_name]['primaryKey'].append(str(column.name))

 # 是否自动递增
 table_dict[table_name]['columns'][str(column.name)][
 'is_autoincrement'] = True if column.autoincrement is True else False

 if column.foreign_keys:
 # Traverse each foreign_key to get corresponding attributes
 for foreign_key in column.foreign_keys:
 table_dict[table_name]['foreign_keys'].append({
 'key': str(column.name),
 'target_table': str(foreign_key.column).split('.')[0],
 'target_key': str(foreign_key.column).split('.')[1]
 })

 return table_dict