java整合datax mysql 增量同步，不使用shell脚本运行，使用纯java代码如何实现

要实现Java整合DataX MySQL增量同步，可以使用DataX的Java API来完成。

首先，需要在pom.xml文件中添加DataX相关依赖：

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>datax-core</artifactId>
    <version>${datax.version}</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>datax-commons</artifactId>
    <version>${datax.version}</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>datax-transport</artifactId>
    <version>${datax.version}</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>datax-plugin-rdbms-util</artifactId>
    <version>${datax.version}</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>datax-plugin-rdbms-reader</artifactId>
    <version>${datax.version}</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>datax-plugin-rdbms-writer</artifactId>
    <version>${datax.version}</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql.version}</version>
</dependency>

其中，`${datax.version}`和`${mysql.version}`需要自行定义。

接下来，创建DataX的配置文件，以JSON格式保存在本地，例如：

{
    "job": {
        "setting": {
            "speed": {
                "channel": 3
            }
        },
        "content": [
            {
                "reader": {
                    "name": "mysqlreader",
                    "parameter": {
                        "username": "root",
                        "password": "123456",
                        "column": [
                            "id",
                            "name",
                            "age"
                        ],
                        "splitPk": "id",
                        "connection": [
                            {
                                "jdbcUrl": "jdbc:mysql://localhost:3306/test",
                                "table": [
                                    "user"
                                ]
                            }
                        ]
                    }
                },
                "writer": {
                    "name": "mysqlwriter",
                    "parameter": {
                        "username": "root",
                        "password": "123456",
                        "column": [
                            "id",
                            "name",
                            "age"
                        ],
                        "preSql": "insert into user(id,name,age) values(?,?,?) on duplicate key update name=values(name),age=values(age)",
                        "connection": [
                            {
                                "jdbcUrl": "jdbc:mysql://localhost:3306/test",
                                "table": [
                                    "user"
                                ]
                            }
                        ]
                    }
                }
            }
        ]
    }
}

其中，需要配置MySQL的连接信息、表名、字段、增量同步字段等信息。

最后，在Java代码中读取配置文件，并执行DataX任务：

public class DataXJob {

    public static void main(String[] args) {
        try {
            // 读取配置文件
            String jobConfig = FileUtils.readFileToString(new File("job.json"), "UTF-8");
            Configuration configuration = Configuration.from(jobConfig);

            // 执行DataX任务
            Engine engine = new Engine();
            engine.start(configuration);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

这样就可以通过Java代码实现DataX和MySQL的增量同步了。