// Path: cango-common/src/main/java/com/bella/cango/enums/DbType.java
// public enum DbType {
//     MYSQL(1, "com.mysql.jdbc.Driver"),
//     ORACLE(2, "oracle.jdbc.driver.OracleDriver"),
//     DRDS(3, "com.mysql.jdbc.Driver");
// 
//     private Integer code;
//     private String driver;
// 
//     DbType(Integer type, String driver) {
//         this.code = type;
//     }
// 
//     public Integer getCode() {
//         return code;
//     }
// 
//     public String getDriver() {
//         return driver;
//     }
// 
//     public boolean isOracle() {
//         return this.equals(ORACLE);
//     }
// 
// 
//     public boolean isMysql() {
//         return this.equals(MYSQL);
//     }
// 
//     public boolean isDRDS() {
//         return this.equals(DRDS);
//     }
// 
//     public DbType parse(Integer code) {
//         switch (code) {
//             case 1:
//                 return MYSQL;
//             case 2:
//                 return ORACLE;
//             case 3:
//                 return DRDS;
//             default:
//                 return null;
//         }
//     }
// }


import com.bella.cango.enums.DbType;
import javax.sql.DataSource;
package com.bella.cango.instance.oracle.common.model;




/**
 * yugong数据处理上下文
 *
 * @author kevin
 */
public class YuGongContext {

    // 具体每张表的同步
    private boolean ignoreSchema = false;  // 同步时是否忽略schema，oracle迁移到mysql可能schema不同，可设置为忽略

    // 全局共享
    private RunMode runMode;
    private int onceCrawNum;                   // 每次提取的记录数
    private int tpsLimit = 0;      // <=0代表不限制
    private DataSource sourceDs;                      // 源数据库链接
    private boolean batchApply = false;
    private boolean skipApplierException = false;  // 是否允许跳过applier异常
    private String sourceEncoding = "UTF-8";
// Path: cango-common/src/main/java/com/bella/cango/enums/DbType.java
// public enum DbType {
//     MYSQL(1, "com.mysql.jdbc.Driver"),
//     ORACLE(2, "oracle.jdbc.driver.OracleDriver"),
//     DRDS(3, "com.mysql.jdbc.Driver");
// 
//     private Integer code;
//     private String driver;
// 
//     DbType(Integer type, String driver) {
//         this.code = type;
//     }
// 
//     public Integer getCode() {
//         return code;
//     }
// 
//     public String getDriver() {
//         return driver;
//     }
// 
//     public boolean isOracle() {
//         return this.equals(ORACLE);
//     }
// 
// 
//     public boolean isMysql() {
//         return this.equals(MYSQL);
//     }
// 
//     public boolean isDRDS() {
//         return this.equals(DRDS);
//     }
// 
//     public DbType parse(Integer code) {
//         switch (code) {
//             case 1:
//                 return MYSQL;
//             case 2:
//                 return ORACLE;
//             case 3:
//                 return DRDS;
//             default:
//                 return null;
//         }
//     }
// }


// Path: cango-instance/src/main/java/com/bella/cango/instance/oracle/common/model/YuGongContext.java
import com.bella.cango.enums.DbType;
import javax.sql.DataSource;

package com.bella.cango.instance.oracle.common.model;




/**
 * yugong数据处理上下文
 *
 * @author kevin
 */
public class YuGongContext {

    // 具体每张表的同步
    private boolean ignoreSchema = false;  // 同步时是否忽略schema，oracle迁移到mysql可能schema不同，可设置为忽略

    // 全局共享
    private RunMode runMode;
    private int onceCrawNum;                   // 每次提取的记录数
    private int tpsLimit = 0;      // <=0代表不限制
    private DataSource sourceDs;                      // 源数据库链接
    private boolean batchApply = false;
    private boolean skipApplierException = false;  // 是否允许跳过applier异常
    private String sourceEncoding = "UTF-8";
    private DbType sourceDbType = DbType.ORACLE;