PXC集群使用

@SpringBootApplication
public class DataImport implements ApplicationListener<ApplicationReadyEvent>, CommandLineRunner {

  @Autowired
  private JdbcTemplate jdbcTemplate;
  @Autowired
  private ConfigurableApplicationContext applicationContext;
  static private Logger logger = LoggerFactory.getLogger(DataImport.class);

  // 数据文件目录
  private static File dataDir;
  // 表名
  private static String tableName;

  public static void main(String[] args) {
    SpringApplication.run(DataImport.class, args);
  }

  @Override
  public void run(String... args) throws Exception {
    if( args == null || args.length != 2 ) {
      logger.error("请输入数据文件目录路径和表名");
      applicationContext.close();
      return;
    }

    File file = new File(args[0]);

    if( !file.isDirectory() ) {
      logger.error("第一个参数为目录路径");
      applicationContext.close();
    }
    DataImport.dataDir = file;
    DataImport.tableName=args[1];
  }

  @Override
  public void onApplicationEvent(ApplicationReadyEvent event) {
    ExecutorService executorService = Executors.newFixedThreadPool(10);
    for (int i = 0; i < dataDir.listFiles().length; i++) {
      File[] files = dataDir.listFiles();
      executorService.execute(new DataImportTask(files[i].getAbsolutePath() , tableName, jdbcTemplate));
    }
  }
}

class DataImportTask implements Runnable{

  private JdbcTemplate jdbcTemplate;
  private String fileFullPath;
  private String tableName;

  public DataImportTask(String fileFullPath, String tableName, JdbcTemplate jdbcTemplate) {
    this.fileFullPath = fileFullPath;
    this.tableName = tableName;
    this.jdbcTemplate = jdbcTemplate;
  }

  @Override
  public void run() {
    String sql = "load data infile '"+ fileFullPath + "' ignore into table " + tableName +" character set 'utf8' " +
      "fields terminated by ',' " +     // 分割符
      "optionally enclosed by '\"' " +
      "lines terminated by '\\n'" +   // 行结束符
      "(ID,DATA_SOURCE,DATA_SOURCE_ID,ISBN,TITLE,IMG,BRIEF,PUBLISH_NAME,AUTHOR,PUBLISH_TIME,PRICE,BOOK_CLC_CODE,CURRENCY,CREATE_TIME,UPDATE_TIME,HAS_MARC,MIS_NO)"; //字段定义
    jdbcTemplate.execute(sql);
  }
}

@SpringBootApplication
public class OptimizeTables  implements ApplicationListener<ApplicationReadyEvent>{

  static private Logger logger = LoggerFactory.getLogger(OptimizeTables.class);
  @Autowired
  private JdbcTemplate jdbcTemplate;
  @Autowired
  private ConfigurableApplicationContext applicationContext;

  public static void main(String[] args) {
    SpringApplication.run(OptimizeTables.class, args);
  }

  @Override
  public void onApplicationEvent(ApplicationReadyEvent event) {
    List<String> tableNames = jdbcTemplate.queryForList("show tables", String.class);
    for (String tableName : tableNames) {
      jdbcTemplate.execute("ALTER TABLE " + tableName + " ENGINE = Innodb");
      logger.info("表【{}】碎片整理完成", tableName);
    }
    logger.info("碎片整理全部完成。。。准备关闭容器");
  }
}

@SpringBootApplication
@EnableScheduling
public class IncrementBackup implements CommandLineRunner {

  static private Logger logger = LoggerFactory.getLogger(IncrementBackup.class);

  private String configPath;

  @Autowired
  private ConfigurableApplicationContext applicationContext;

  public static void main(String[] args) {
    SpringApplication.run(IncrementBackup.class, args);
  }

  @Override
  public void run(String... args) throws Exception {
    if(args == null || args.length == 0) {
      logger.error("请指定配置文件位置");
      applicationContext.close();
    } else {
      configPath = args[0];
      logger.info("加载配置文件[{}]", configPath);
    }
  }

  // 这个需要调整时间
  @Scheduled(cron = "0 */2 * * * ?")
  public void incrementScheduling() throws IOException {
    Yaml yaml = new Yaml();
    InputStream configInputStream=new FileInputStream(configPath);
    //读入文件
    Map<String,String> content= (Map) yaml.load(configInputStream);
    configInputStream.close();

    String host = content.get("host");
    String user = content.get("user");
    String password = content.get("password");
    String port = content.get("port");
    String baseDir = content.get("baseDir");
    String incrementDir = content.get("incrementDir");

    String folderName = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
    String shellCmd = "innobackupex --default-file=/etc/my.cnf " +
      "--host={0} " +
      "--user={1} " +
      "--password={2} " +
      "--port={3} " +
      "--incremental-basedir={4} " +
      "--no-timestamp " +	//不再在生成一个时间文件夹包裹备份文件
      "--incremental {5}";
    shellCmd = MessageFormat.format(shellCmd, host, user, password, port, baseDir, incrementDir + File.separator + folderName);
    logger.info("shellCmd : {}", shellCmd);

    Runtime.getRuntime().exec(shellCmd);

    content.put("baseDir", incrementDir + File.separator + folderName);
    Writer writer = new FileWriter(configPath);
    yaml.dump(content, writer);
    writer.close();
  }
}