[datax数据库同步]基于datax的数据同步平台

createdatabaseFirstBlooddefaultcharactersetutf8collateutf8_bin;

CREATETABLE`databaseinfo`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`name`varchar(255)DEFAULTNULLCOMMENT‘名称‘,

`description`varchar(255)DEFAULTNULLCOMMENT‘描述‘,

`host`varchar(255)DEFAULTNULLCOMMENT‘主机‘,

`user`varchar(255)DEFAULTNULLCOMMENT‘用户‘,

`passwd`varchar(255)DEFAULTNULLCOMMENT‘密码‘,

`db`varchar(255)DEFAULTNULLCOMMENT‘数据库‘,

`type`varchar(255)DEFAULTNULLCOMMENT‘类型‘,

`create_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘创建时间‘,

`modify_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMPCOMMENT‘修改时间‘,

PRIMARYKEY(`id`),

UNIQUEKEY`databaseinfo_host_c254f05e_uniq`(`host`),

UNIQUEKEY`databaseinfo_name_a3bc8190_uniq`(`name`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘数据库信息‘;

droptableifexists`datax_job`;

CREATETABLE`datax_job`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`name`varchar(255)DEFAULTNULLCOMMENT‘名称‘,

`description`varchar(255)DEFAULTNULLCOMMENT‘描述‘,

`querySql`longtextCOLLATEutf8_binNOTNULLCOMMENT‘查询SQL语句‘,

`reader_databaseinfo_id`int(11)NOTNULLCOMMENT‘读取数据库‘,

`writer_table`varchar(255)DEFAULTNULLCOMMENT‘写入表名‘,

`writer_databaseinfo_id`int(11)NOTNULLCOMMENT‘写入数据库‘,

`writer_preSql`longtextCOLLATEutf8_binNOTNULLCOMMENT‘写入数据前执行的SQL语句‘,

`writer_postSql`longtextCOLLATEutf8_binNOTNULLCOMMENT‘写入数据后执行的SQL语句‘,

`create_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘创建时间‘,

`modify_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMPCOMMENT‘修改时间‘,

PRIMARYKEY(`id`),

UNIQUEKEY`datax_job_name_uniq`(`name`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘datax数据同步任务‘;

droptableifexists`datax_job_writer_column`;

CREATETABLE`datax_job_writer_column`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`name`varchar(255)DEFAULTNULLCOMMENT‘列名‘,

`datax_job_id`int(11)NOTNULLCOMMENT‘数据同步任务ID‘,

`create_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘创建时间‘,

`modify_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMPCOMMENT‘修改时间‘,

PRIMARYKEY(`id`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘写入表的列信息‘;

droptableifexists`datax_job_instance`;

CREATETABLE`datax_job_instance`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`instance_id`bigint(20)NOTNULLCOMMENT‘任务实例ID‘,

`name`varchar(255)DEFAULTNULLCOMMENT‘名称‘,

`description`varchar(255)DEFAULTNULLCOMMENT‘描述‘,

`querySql`longtextCOLLATEutf8_binNOTNULLCOMMENT‘查询SQL语句‘,

`reader_databaseinfo_host`varchar(255)NOTNULLCOMMENT‘读取数据库IP‘,

`reader_databaseinfo_description`varchar(255)NOTNULLCOMMENT‘读取数据库描述‘,

`writer_table`varchar(255)DEFAULTNULLCOMMENT‘写入表名‘,

`writer_databaseinfo_host`varchar(255)NOTNULLCOMMENT‘写入数据库IP‘,

`writer_databaseinfo_description`varchar(255)NOTNULLCOMMENT‘写入数据库描述‘,

`writer_preSql`longtextCOLLATEutf8_binNOTNULLCOMMENT‘写入数据前执行的SQL语句‘,

`writer_postSql`longtextCOLLATEutf8_binNOTNULLCOMMENT‘写入数据后执行的SQL语句‘,

`trigger_mode`int(2)DEFAULT‘1‘COMMENT‘触发模式1自动2手动(默认自动)‘,

`status`int(2)DEFAULT‘0‘COMMENT‘状态0正在执行1执行完成‘,

`result`int(2)DEFAULT‘2‘COMMENT‘执行结果0成功1失败2未知‘,

`start_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘开始时间‘,

`end_time`datetimeDEFAULTNULLCOMMENT‘结束时间‘,

PRIMARYKEY(`id`),

UNIQUEKEY`datax_job_instance_id_uniq`(`instance_id`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘datax数据同步任务实例‘;

droptableifexists`batch_job`;

CREATETABLE`batch_job`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`name`varchar(255)DEFAULTNULLCOMMENT‘名称‘,

`description`varchar(255)DEFAULTNULLCOMMENT‘描述‘,

`create_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘创建时间‘,

`modify_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMPCOMMENT‘修改时间‘,

PRIMARYKEY(`id`),

UNIQUEKEY`batch_job_name_uniq`(`name`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘批处理作业‘;

droptableifexists`batch_job_details`;

CREATETABLE`batch_job_details`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`batch_job_id`int(11)NOTNULLCOMMENT‘批处理作业ID‘,

`subjob_id`int(11)NOTNULLCOMMENT‘子作业ID‘,

`type`int(2)NOTNUllCOMMENT‘类型1数据同步2SQL脚本3备份。主要用于后期扩展‘,

`create_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘创建时间‘,

`modify_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMPCOMMENT‘修改时间‘,

PRIMARYKEY(`id`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘批处理作业详情‘;

droptableifexists`batch_job_instance`;

CREATETABLE`batch_job_instance`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`instance_id`bigint(20)NOTNULLCOMMENT‘实例ID‘,

`name`varchar(255)DEFAULTNULLCOMMENT‘名称‘,

`description`varchar(255)DEFAULTNULLCOMMENT‘描述‘,

`trigger_mode`int(2)DEFAULT‘1‘COMMENT‘触发模式1自动2手动(默认自动)‘,

`status`int(2)DEFAULT‘0‘COMMENT‘状态0正在执行1执行完成‘,

`result`int(2)DEFAULT‘2‘COMMENT‘执行结果0成功1失败2未知‘,

`start_time`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPCOMMENT‘开始时间‘,

`end_time`datetimeDEFAULTNULLCOMMENT‘结束时间‘,

PRIMARYKEY(`id`),

UNIQUEKEY`batch_job_instance_id_uniq`(`instance_id`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘批处理作业执行实例‘;

droptableifexists`batch_job_instance_details`;

CREATETABLE`batch_job_instance_details`(

`id`int(11)NOTNULLAUTO_INCREMENT,

`instance_id`bigint(20)NOTNULLCOMMENT‘实例ID‘,

`subjob_instance_id`bigint(20)NOTNULLCOMMENT‘子作业实例ID‘,

`type`int(2)NOTNUllCOMMENT‘类型1数据同步2SQL脚本3备份。主要用于后期扩展‘,

PRIMARYKEY(`id`)

)ENGINE=InnoDBAUTO_INCREMENT=28DEFAULTCHARSET=utf8COMMENT=‘批处理作业执行实例详情‘;

[datax数据库同步]基于datax的数据同步平台

上一篇:SQLServer 日期函数大全


下一篇:SQL Server2008函数大全(完整版)