ignite集成mysql

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class IgniteMySQLIntegration {
    public static void main(String[] args) {
        try {
            // 配置Ignite
            IgniteConfiguration cfg = new IgniteConfiguration();
            TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi();
            TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
            ipFinder.setAddresses("127.0.0.1:47500..47509");
            discoverySpi.setIpFinder(ipFinder);
            cfg.setDiscoverySpi(discoverySpi);

            // 启动Ignite
            Ignite ignite = Ignition.start(cfg);

            // 配置缓存
            CacheConfiguration<String, String> cacheCfg = new CacheConfiguration<>("myCache");
            IgniteCache<String, String> cache = ignite.getOrCreateCache(cacheCfg);

            // 连接MySQL
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "user", "password");
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM mytable");

            // 将数据缓存到Ignite
            while (rs.next()) {
                String key = rs.getString("id");
                String value = rs.getString("name");
                cache.put(key, value);
            }

            // 关闭连接
            rs.close();
            stmt.close();
            conn.close();

            ignite.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}