| | |
| | | String AND = " and "; |
| | | String MD = "md_"; |
| | | |
| | | |
| | | String CNT = "cnt"; |
| | | String checkFieldSqlTemplate = "select count(1) as cnt from (select {0} from {1}) a1"; |
| | | String selectRecordFieldSqlTemplate = "select {0}, 0 as deal from {1}"; |
| | |
| | | String STEP_READ_FROM_TABLE = "Read data from table"; |
| | | String STEP_INSERT_UPDATE = "Insert or update"; |
| | | String STEP_DUMMY = "Dummy"; |
| | | String MYSQL_UUID = "replace(UUID(),'-', '')"; |
| | | String MYSQL_UUID = " UUID_SHORT() "; |
| | | String TYPE = "type"; |
| | | String Active = "active"; |
| | | String AssembleTempTable = "hj_table_"; |
| | |
| | | String CreateTableMysql = "CREATE TABLE IF NOT EXISTS `{0}` ({1}) ENGINE=InnoDB DEFAULT CHARSET=utf8;"; |
| | | String checkTableByNameBySchema = "select table_name from information_schema.tables where table_schema={0} and table_name = {1};"; |
| | | String Temp = "temp_"; |
| | | String Temp2RecordMySQLTemplate = "INSERT INTO {0} ({1}) SELECT {2}, replace(uuid(),''-'', '''') as std_id, replace(uuid(),''-'', '''') as id, 0 as deal from {3}"; |
| | | String MYSQLJoinUpdateSql = "INSERT INTO {0} ({1}) SELECT {2} , replace(uuid(),''-'', '''') as id, s1.id as std_id, 0 as deal FROM {3} t1 inner join {4} s1 on {5};"; |
| | | String MYSQLJoinAddSql = "INSERT INTO {0} ({1}) SELECT {2} , replace(uuid(),''-'', '''') as std_id, replace(uuid(),''-'', '''') as id, 0 as deal FROM {3} t1 WHERE NOT EXISTS(SELECT * FROM {4} s1 WHERE {5});"; |
| | | String Temp2RecordMySQLTemplate = "INSERT INTO {0} ({1}) SELECT {2}, UUID_SHORT() as std_id, UUID_SHORT() as id, 0 as deal from {3}"; |
| | | String MYSQLJoinUpdateSql = "INSERT INTO {0} ({1}) SELECT {2} , UUID_SHORT() as id, s1.id as std_id, 0 as deal FROM {3} t1 inner join {4} s1 on {5};"; |
| | | String MYSQLJoinAddSql = "INSERT INTO {0} ({1}) SELECT {2} , UUID_SHORT() as std_id, UUID_SHORT() as id, 0 as deal FROM {3} t1 WHERE NOT EXISTS(SELECT * FROM {4} s1 WHERE {5});"; |
| | | String Temp2RecordHbaseTemplate = "INSERT INTO {0} ({1}) SELECT ({2}, ) from {3}"; |
| | | String ParamsShell = "@\\{{0}\\}"; |
| | | String Cron = "cron"; |
| | |
| | | String FIELD = "field"; |
| | | String DISTINCT = "distinct {0}"; |
| | | String InSql = "{0} in ( {1} )"; |
| | | String asTempSql = "( {0} ) {1}"; |
| | | String z_AllVal = "z_AllVal"; |
| | | |
| | | int queueSize = 20; |
| | | int cntCoefficient = 50; |
| | | String VIEW = "view_"; |
| | | String InnerJoinTemplate = " {0} {1} on {2}"; |
| | | String changedField = "change_field"; |
| | | String XLS = "xls"; |
| | | String xlsx = "xlsx"; |
| | | String LeftJoin = " left join "; |
| | | String InnerJoin = " inner join "; |
| | | String Pre = "pre"; |
| | | String PreValue = "原始值"; |
| | | String fix = "fix"; |
| | | String fixValue = "转换值"; |
| | | String userDO = "userDO"; |
| | | String MasterDispense = "Master-Dispense"; |
| | | String Master = "master"; |
| | | String View = "view"; |
| | | String Token = "token"; |
| | | |
| | | int MaxDispenseSize = Double.valueOf(1024 * 1024 * 0.5).intValue(); |
| | | String RECORDS = "records"; |
| | | String SUCCESSCODE = "200"; |
| | | String Star = "*"; |
| | | String operate = "operate"; |
| | | String timeZone = "serverTimezone"; |
| | | String TM = "tm"; |
| | | String MT = "mt"; |
| | | String IDX_TEMPLATE = "IDX_{0}_{1}"; |
| | | |
| | | } |