Apache Ignite 使用SQL模式

// Register JDBC driver.
Class.forName("org.apache.ignite.IgniteJdbcThinDriver");
 
// Open the JDBC connection.
Connection conn = DriverManager.getConnection("jdbc:ignite:thin://127.0.0.1");

代码测试

创建JavaBean

 
 
import java.io.Serializable;
import java.util.concurrent.atomic.AtomicLong;
import org.apache.ignite.cache.affinity.AffinityKey;
import org.apache.ignite.cache.query.annotations.QuerySqlField;
import org.apache.ignite.cache.query.annotations.QueryTextField;
 
/**
 * Person class.
 */
public class PersonNew implements Serializable {
    /** */
    private static final AtomicLong ID_GEN = new AtomicLong();
 
    /** Name of index by two fields (orgId, salary). */
    public static final String ORG_SALARY_IDX = "ORG_SALARY_IDX";
 
    /** Person ID (indexed). */
    @QuerySqlField(index = true)
    public Long id;
 
    /** Organization ID (indexed). */
    @QuerySqlField(index = true, orderedGroups = @QuerySqlField.Group(name = ORG_SALARY_IDX, order = 0))
    public Long orgId;
 
    /** First name (not-indexed). */
    @QuerySqlField
    public String firstName;
 
    /** Last name (not indexed). */
    @QuerySqlField
    public String lastName;
 
    /** Resume text (create LUCENE-based TEXT index for this field). */
    @QueryTextField
    public String resume;
 
    /** Salary (indexed). */
    @QuerySqlField(index = true, orderedGroups = @QuerySqlField.Group(name = ORG_SALARY_IDX, order = 1))
    public double salary;
 
    /** Custom cache key to guarantee that person is always colocated with its organization. */
    private transient AffinityKey<Long> key;
 
    /**
     * Default constructor.
     */
    public PersonNew() {
        // No-op.
    }
 
//    /**
//     * Constructs person record.
//     *
//     * @param org       Organization.
//     * @param firstName First name.
//     * @param lastName  Last name.
//     * @param salary    Salary.
//     * @param resume    Resume text.
//     */
//    public Person(Organization org, String firstName, String lastName, double salary, String resume) {
//        // Generate unique ID for this person.
//        id = ID_GEN.incrementAndGet();
//
//        orgId = org.id();
//
//        this.firstName = firstName;
//        this.lastName = lastName;
//        this.salary = salary;
//        this.resume = resume;
//    }
 
    /**
     * Constructs person record.
     *
     * @param id Person ID.
     * @param orgId Organization ID.
     * @param firstName First name.
     * @param lastName Last name.
     * @param salary    Salary.
     * @param resume    Resume text.
     */
    public PersonNew(Long id, Long orgId, String firstName, String lastName, double salary, String resume) {
        this.id = id;
        this.orgId = orgId;
        this.firstName = firstName;
        this.lastName = lastName;
        this.salary = salary;
        this.resume = resume;
    }
 
    /**
     * Constructs person record.
     *
     * @param id Person ID.
     * @param firstName First name.
     * @param lastName Last name.
     */
    public PersonNew(Long id, String firstName, String lastName) {
        this.id = id;
 
        this.firstName = firstName;
        this.lastName = lastName;
    }
 
    /**
     * Gets cache affinity key. Since in some examples person needs to be collocated with organization, we create
     * custom affinity key to guarantee this collocation.
     *
     * @return Custom affinity key to guarantee that person is always collocated with organization.
     */
    public AffinityKey<Long> key() {
        if (key == null)
            key = new AffinityKey<>(id, orgId);
 
        return key;
    }
 
    /**
     * {@inheritDoc}
     */
    @Override public String toString() {
        return "Person [id=" + id +
                ", orgId=" + orgId +
                ", lastName=" + lastName +
                ", firstName=" + firstName +
                ", salary=" + salary +
                ", resume=" + resume + ']';
    }
}

创建测试类

package ignite.sql;
 
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.query.FieldsQueryCursor;
import org.apache.ignite.cache.query.SqlFieldsQuery;
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.multicast.TcpDiscoveryMulticastIpFinder;
 
import javax.cache.Cache;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
 
public class PersonBean {
 
    /**
     * Persons cache name.
     */
    private static final String PERSON_CACHE = PersonBean.class.getSimpleName() + "PersonNew";
 
    public static void main(String[] args) {
 
        // Preparing IgniteConfiguration using Java APIs
        IgniteConfiguration cfg = new IgniteConfiguration();
 
        // The node will be started as a client node.
        cfg.setClientMode(true);
 
        // Classes of custom Java logic will be transferred over the wire from this app.
        cfg.setPeerClassLoadingEnabled(true);
 
        // Setting up an IP Finder to ensure the client can locate the servers.
        TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
        ArrayList<String> strings = new ArrayList<>();
        strings.add("127.0.0.1:47500..47509");
        //ipFinder.setAddresses(Collections.singletonList("192.168.165.42:47500..47509"));
        ipFinder.setAddresses(strings);
        cfg.setDiscoverySpi(new TcpDiscoverySpi().setIpFinder(ipFinder));
        try (Ignite ignite = Ignition.start(cfg)) {
 
            CacheConfiguration<Long, PersonNew> personCacheCfg = new CacheConfiguration<>(PERSON_CACHE);
            personCacheCfg.setIndexedTypes(Long.class, PersonNew.class);
            IgniteCache<Long, PersonNew> personCache = ignite.getOrCreateCache(personCacheCfg);
 
            // Insert persons.
//            SqlFieldsQuery qry = new SqlFieldsQuery(
//                    "insert into PersonNew (_key, id, orgId, firstName, lastName, salary, resume) values (?, ?, ?, ?, ?, ?, ?)");
//
//            personCache.query(qry.setArgs(1L, 1L, 1L, "John", "Doe", 4000.00, "Master"));
//            personCache.query(qry.setArgs(2L, 2L, 1L, "Jane", "Roe", 2000.00, "Bachelor"));
//            personCache.query(qry.setArgs(3L, 3L, 2L, "Mary", "Major", 5000.00, "Master"));
//            personCache.query(qry.setArgs(4L, 4L, 2L, "Richard", "Miles", 3000.00, "Bachelor"));
 
            PersonNew personNew = personCache.get(1L);
            System.out.println(personNew);
            PersonNew p2 = new PersonNew(5L, 5L, "city", "bob", 5000.00, "Master");
            personCache.put(5L, p2);
            SqlFieldsQuery query = new SqlFieldsQuery("SELECT *  FROM PersonNew ");
            FieldsQueryCursor<List<?>> cursor = personCache.query(query);
            Iterator<List<?>> iterator = cursor.iterator();
            System.out.println("Query result:");
 
            while (iterator.hasNext()) {
                List<?> row = iterator.next();
                // System.out.println(">>>    " + row.get(0) + ", " + row.get(1));
                //System.out.println(">>>    " + row.get(0));
                System.out.println(row);
            }
 
 
 
            // Cache<Long, PersonNew> cache = Ignition.ignite().cache();
 
            // Create query which selects salaries based on range for all employees
            // that work for a certain company.
//            CacheQuery<Map.Entry<Long, Person>> qry = cache.queries().createSqlQuery(Person.class,
//                    "from Person, Organization where Person.orgId = Organization.id " +
//                            "and Organization.name = ? and Person.salary > ? and Person.salary <= ?");
 
            // Query all nodes to find all cached Ignite employees
            // with salaries less than 1000.
            //qry.execute("Ignition", 0, 1000);
 
            // Query only remote nodes to find all remotely cached Ignite employees
            // with salaries greater than 1000 and less than 2000.
            // qry.projection(grid.remoteProjection()).execute("Ignition", 1000, 2000);
        }
    }
}

通过DBeaver查看创建的表，默认会创建一个库。

创建连接

 查看表结构

 

查看表数据