ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vyacheslav Koptilin (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (IGNITE-7411) JDBC thin client selects NULL cache ID values of entries added with Java API
Date Mon, 15 Jan 2018 14:32:00 GMT

     [ https://issues.apache.org/jira/browse/IGNITE-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Vyacheslav Koptilin updated IGNITE-7411:
----------------------------------------
    Description: 
I am using SQL to create caches and run queries and DataStreamer to load lots of data. I must
use MD5 digests as entity IDs (BINARY(16) SQL type). The problem is when I select data loaded
with DataStreamer the fields participating in PRIMARY KEY are null.
 * Note: binary fields not part of primary keys are OK (not null)
 * Note: if I use JAVA API even the binary primary key fields are OK (not null).

Reproducer below fails on the last assertion since SSN is NULL.

See full reproducer code in branch ignite-7411 or use the reproducer attached.
{code:java}
    @Test
    public void javaPutIntoSqlCacheWithBinaryAffinityKey() throws SQLException {
        try (Ignite srv = Ignition.start(getServerConfig());
             Ignite cln = Ignition.start(getClientConfig());
             Connection conn = DriverManager.getConnection("jdbc:ignite:thin://127.0.0.1/")
        ) {
            conn.prepareStatement(
                "CREATE TABLE " + CACHE_NAME + "(" +
                    "ssn BINARY(16), orgId BINARY(16), name BINARY(16), PRIMARY KEY(ssn, orgId)"
+
                    ") WITH \"affinitykey=orgId,value_type=org.apache.ignite.Reproducer$Person\""
            ).execute();

            IgniteCache<AffinityKey<byte[]>, Person> cache = cln.cache("SQL_PUBLIC_"
+ CACHE_NAME);

            AffinityKey<byte[]> key = new AffinityKey<>(new byte[] {1, 2}, new
byte[] {3, 4});

            cache.put(key, new Person(key.key(), key.affinityKey(), new byte[] {5, 6}));

            List<Person> entries = convert(conn.prepareStatement("SELECT * from " +
CACHE_NAME).executeQuery());

            assertEquals("1 person must be in the cache", 1, entries.size());

            assertArrayEquals("Person SSN must be same as affinity key's key", key.key(),
entries.get(0).getSsn());
        }
    }

    /** */
    private List<Person> convert(ResultSet resSet) throws SQLException {
        List<Person> res = new ArrayList<>();

        while (resSet.next())
            res.add(new Person(resSet.getBytes(1), resSet.getBytes(2), resSet.getBytes(3)));

        return res;
    }
{code}
 

  was:
I am using SQL to create caches and run queries and DataStreamer to load lots of data. I must
use MD5 digests as entity IDs (BINARY(16) SQL type). The problem is when I select data loaded
with DataStreamer the fields participating in PRIMARY KEY are null.
 * Note: binary fields not part of primary keys are OK (not null)
 * Note: if I use JAVA API even the binary primary key fields are OK (not null).

Reproducer below fails on the last assertion since SSN is NULL.

See full reproducer code in branch ignite-7411 or use the reproducer attached.
{code:java}
    @Test
    public void javaPutIntoSqlCacheWithBinaryAffinityKey() throws SQLException {
        try (Ignite srv = Ignition.start(getServerConfig());
             Ignite cln = Ignition.start(getClientConfig());
             Connection conn = DriverManager.getConnection("jdbc:ignite:thin://127.0.0.1/")
        ) {
            conn.prepareStatement(
                "CREATE TABLE " + CACHE_NAME + "(" +
                    "ssn BINARY(16), orgId BINARY(16), name BINARY(16), PRIMARY KEY(ssn, orgId)"
+
                    ") WITH \"affinitykey=orgId,value_type=org.apache.ignite.Reproducer$Person\""
            ).execute();

            IgniteCache<AffinityKey<byte[]>, Person> cache = cln.cache("SQL_PUBLIC_"
+ CACHE_NAME);

            AffinityKey<byte[]> key = new AffinityKey<>(new byte[] {1, 2}, new
byte[] {3, 4});

            cache.put(key, new Person(key.key(), key.affinityKey(), new byte[] {5, 6}));

            List<Person> entries = convert(conn.prepareStatement("SELECT * from " +
CACHE_NAME).executeQuery());

            assertEquals("1 person must be in the cache", 1, entries.size());

            assertArrayEquals("Person SSN must be same as affinity key's key", key.key(),
entries.get(0).getSsn());
        }
    }

    /** */
    private List<Person> convert(ResultSet resSet) throws SQLException {
        List<Person> res = new ArrayList<>();

        while (resSet.next())
            res.add(new Person(resSet.getBytes(1), resSet.getBytes(2), resSet.getBytes(3)));

        return res;
    }
{code}
 
The issue was initially discussed on user-list: http://apache-ignite-users.70518.x6.nabble.com/Error-of-start-with-multiple-data-regions-td19116.html


> JDBC thin client selects NULL cache ID values of entries added with Java API
> ----------------------------------------------------------------------------
>
>                 Key: IGNITE-7411
>                 URL: https://issues.apache.org/jira/browse/IGNITE-7411
>             Project: Ignite
>          Issue Type: Bug
>          Components: thin client
>    Affects Versions: 2.3
>            Reporter: Alexey Kukushkin
>            Priority: Critical
>         Attachments: Reproducer.java
>
>
> I am using SQL to create caches and run queries and DataStreamer to load lots of data.
I must use MD5 digests as entity IDs (BINARY(16) SQL type). The problem is when I select
data loaded with DataStreamer the fields participating in PRIMARY KEY are null.
>  * Note: binary fields not part of primary keys are OK (not null)
>  * Note: if I use JAVA API even the binary primary key fields are OK (not null).
> Reproducer below fails on the last assertion since SSN is NULL.
> See full reproducer code in branch ignite-7411 or use the reproducer attached.
> {code:java}
>     @Test
>     public void javaPutIntoSqlCacheWithBinaryAffinityKey() throws SQLException {
>         try (Ignite srv = Ignition.start(getServerConfig());
>              Ignite cln = Ignition.start(getClientConfig());
>              Connection conn = DriverManager.getConnection("jdbc:ignite:thin://127.0.0.1/")
>         ) {
>             conn.prepareStatement(
>                 "CREATE TABLE " + CACHE_NAME + "(" +
>                     "ssn BINARY(16), orgId BINARY(16), name BINARY(16), PRIMARY KEY(ssn,
orgId)" +
>                     ") WITH \"affinitykey=orgId,value_type=org.apache.ignite.Reproducer$Person\""
>             ).execute();
>             IgniteCache<AffinityKey<byte[]>, Person> cache = cln.cache("SQL_PUBLIC_"
+ CACHE_NAME);
>             AffinityKey<byte[]> key = new AffinityKey<>(new byte[] {1, 2},
new byte[] {3, 4});
>             cache.put(key, new Person(key.key(), key.affinityKey(), new byte[] {5, 6}));
>             List<Person> entries = convert(conn.prepareStatement("SELECT * from
" + CACHE_NAME).executeQuery());
>             assertEquals("1 person must be in the cache", 1, entries.size());
>             assertArrayEquals("Person SSN must be same as affinity key's key", key.key(),
entries.get(0).getSsn());
>         }
>     }
>     /** */
>     private List<Person> convert(ResultSet resSet) throws SQLException {
>         List<Person> res = new ArrayList<>();
>         while (resSet.next())
>             res.add(new Person(resSet.getBytes(1), resSet.getBytes(2), resSet.getBytes(3)));
>         return res;
>     }
> {code}
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message