datax-admin/app/schemas/job_jdbc_datasouce.py

from typing import List, Optional

from pydantic import BaseModel


class JobJdbcDatasourceBase(BaseModel):
    # 数据源名称
    datasource_name: str
    # 数据源
    datasource: str
    # 数据库名
    database_name: str
    # 数据库用户名
    jdbc_username: Optional[str]
    # 数据库密码
    jdbc_password: Optional[str]
    # jdbc url
    jdbc_url: str
    # 备注
    comments: str
    # 标签
    tag: str
    # kerberos 验证(0:未开启，1:开启)
    kerberos: int
    # keytab 文件
    keytab: Optional[str]
    # krb5config 文件
    krb5config: Optional[str]
    # service 名称
    kerberos_service_name: Optional[str]
    # principal
    principal: Optional[str]
    class Config:
        schema_extra = {
            # "example": {
            #     "datasource_name": 'test',
            #     "datasource": "mysql",
            #     "database_name": 'datax_web',
            #     "jdbc_username": 'root',
            #     "jdbc_password": 'happylay',
            #     "jdbc_url": '192.168.199.107:10086',
            #     "comments": 'This is a very nice Item',
            #     "tag": '线下'
            # }
            "example": {
                "datasource_name": 'testhive',
                "datasource": "hive",
                "database_name": 'default',
                "jdbc_username": '',
                "jdbc_password": '',
                "jdbc_url": '192.168.199.107:10000',
                "comments": 'This is a very nice Item',
                "tag": '线下',
                "kerberos": 0,
                "keytab": "test/kerberos/user.keytab",
                "krb5config": "test/kerberos/user.conf",
                "kerberos_service_name": "hadoop",
                "principal": "ailab@EMR-5XJSY31F",
            }
        }


class JobJdbcDatasourceCreate(JobJdbcDatasourceBase):
    pass


class JobJdbcDatasourceUpdate(JobJdbcDatasourceBase):
    status: int = 1
    class Config:
        schema_extra = {
            # "example": {
            #     "datasource_name": 'test',
            #     "datasource": "mysql",
            #     "database_name": 'datax_web',
            #     "jdbc_username": 'root',
            #     "jdbc_password": 'happylay',
            #     "jdbc_url": '192.168.199.107:10086',
            #     "comments": 'This is a very nice Item',
            #     "tag": '线下',
            #     "status": 1,
            # }
            "example": {
                "datasource_name": 'testhive',
                "datasource": "hive",
                "database_name": 'default',
                "jdbc_username": '',
                "jdbc_password": '',
                "jdbc_url": '192.168.199.107:10000',
                "comments": 'This is a very nice Item',
                "tag": '线下',
                "kerberos": 0,
                "keytab": "test/kerberos/user.keytab",
                "krb5config": "test/kerberos/user.conf",
                "kerberos_service_name": "hadoop",
                "principal": "ailab@EMR-5XJSY31F",
                "status": 1,
            }
        }

class JobJdbcDatasource(JobJdbcDatasourceBase):
    id: int
    status: int
    create_time: int
    create_by: str
    update_time: int
    update_by: str
    jdbc_url: str
    jdbc_driver_class: str

    class Config:
        orm_mode = True