[
https://issues.apache.org/jira/browse/IGNITE-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kukushkin updated IGNITE-7411:
-------------------------------------
Attachment: Reproducer.java
> 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.
> @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());
> }
> }
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
