| Re: [eclipselink-dev] Fix for bug# 295556 - Do not add Distinct to Queries that including a Lob field - in DB2 |
I’ve switched to using Oracle for the database, and still cannot reproduce with ECL 2.5.0. Switching to use a ReadAllQuery did not change the outcome, either (attempt left commented out.) [EL Info]: 2014-09-04 10:01:31.001--ServerSession(544214961)--EclipseLink, version: Eclipse Persistence Services - 2.5.0.v20130507-3faac2b ... [EL Fine]: sql: 2014-09-04 10:01:33.078--ServerSession(544214961)--Connection(1725418407)--CREATE TABLE ECL295ENTA (ID NUMBER(10) NOT NULL, STRDATA VARCHAR2(255) NULL, STRINGVALUE CLOB NULL, PRIMARY KEY (ID)) [EL Fine]: sql: 2014-09-04 10:01:33.148--ServerSession(544214961)--Connection(1725418407)--CREATE TABLE ECL295ENTB (ID NUMBER(10) NOT NULL, STRDATA VARCHAR2(255) NULL, PRIMARY KEY (ID)) [EL Fine]: sql: 2014-09-04 10:01:33.213--ServerSession(544214961)--Connection(1725418407)--CREATE TABLE ECLENTA_ENTB (ECL295EntB_ID NUMBER(10) NOT NULL, entACollection_ID NUMBER(10) NOT NULL, PRIMARY KEY (ECL295EntB_ID, entACollection_ID)) [EL Fine]: sql: 2014-09-04 10:01:33.28--ServerSession(544214961)--Connection(1725418407)--ALTER TABLE ECLENTA_ENTB ADD CONSTRAINT ECLENTA_ENTB_entACollection_ID FOREIGN KEY (entACollection_ID) REFERENCES ECL295ENTA (ID) [EL Fine]: sql: 2014-09-04 10:01:33.348--ServerSession(544214961)--Connection(1725418407)--ALTER TABLE ECLENTA_ENTB ADD CONSTRAINT FK_ECLENTA_ENTB_ECL295EntB_ID FOREIGN KEY (ECL295EntB_ID) REFERENCES ECL295ENTB (ID) … [EL Fine]: sql: 2014-09-04 10:01:40.598--ServerSession(544214961)--Connection(1725418407)--SELECT ID, STRDATA FROM ECL295ENTB [EL Fine]: sql: 2014-09-04 10:01:40.708--ServerSession(544214961)--Connection(1725418407)--SELECT t1.ID, t1.STRDATA, t1.STRINGVALUE, t0.ECL295EntB_ID FROM ECLENTA_ENTB t0, ECL295ENTB t2, ECL295ENTA t1 WHERE ((t0.ECL295EntB_ID = t2.ID) AND (t1.ID = t0.entACollection_ID)) Entity Definitions are still: @Entity public class ECL295EntA { @Id private int id; @Basic private String strData; @Lob String stringValue; … } @Entity public class ECL295EntB { @Id private int id; @Basic private String strData; @ManyToMany(cascade = {CascadeType.PERSIST, CascadeType.REMOVE}) @JoinTable(name="ECLENTA_ENTB") @MapKey(name="strData") private Map<String, ECL295EntA> entACollection; … } With the executing test: public class TestD295556 { @Test public void test002() { EntityManagerFactory emf = javax.persistence.Persistence.createEntityManagerFactory("testpu"); populateDB(emf); EntityManager em = emf.createEntityManager(); // ReadAllQuery raQuery = new ReadAllQuery(ECL295EntB.class); // raQuery.setJPQLString("SELECT OBJECT(b) FROM ECL295EntB b"); // List resultSet = (List) ((org.eclipse.persistence.internal.jpa.EntityManagerImpl) em).getSession().executeQuery(raQuery); Query q = em.createQuery("SELECT OBJECT(b) from ECL295EntB b"); q.setHint(QueryHints.BATCH , "b.entACollection"); q.setHint(QueryHints.QUERY_TYPE, QueryType.ReadObject); List<ECL295EntB> resultSet = q.getResultList(); assertNotNull(resultSet); ECL295EntB entB_find = (ECL295EntB) resultSet.get(0); // em.find(ECL295EntB.class, 1); assertNotNull(entB_find); boolean containsTarget = entB_find.getEntACollection().containsKey("EntA-1"); assertTrue(containsTarget); assertEquals(10, entB_find.getEntACollection().size()); } private void populateDB(EntityManagerFactory emf) { System.out.println("Populating DB..."); EntityManager em = emf.createEntityManager(); em.getTransaction().begin(); em.createNativeQuery("DELETE FROM ECLENTA_ENTB").executeUpdate(); em.createNativeQuery("DELETE FROM ECLENTA_ENTB2").executeUpdate(); em.createNativeQuery("DELETE FROM ECL295EntA").executeUpdate(); em.createNativeQuery("DELETE FROM ECL295EntB").executeUpdate(); em.getTransaction().commit(); em.close(); em = emf.createEntityManager(); em.getTransaction().begin(); final int entBCount = 10; ECL295EntB[] entBArr = new ECL295EntB[entBCount]; SecureRandom sr = new SecureRandom(); for (int i = 0; i < entBCount; i++) { ECL295EntB entB = new ECL295EntB(); entB.setId(i+1); entB.setStrData("Entity B-" + i); em.persist(entB); entBArr[i] = entB; } for (int i = 0; i < 10; i++) { ECL295EntA entA = new ECL295EntA(); entA.setId(i+1); entA.setStrData("EntA-" + i); StringBuffer sb = new StringBuffer(); for (int j = 0; j < 200; j++) { sb.append(sr.nextLong());sb.append(' '); } entA.setStringValue(sb.toString()); for (int j = 0; j < entBCount; j++) { entBArr[j].getEntACollection().put(entA.getStrData(), entA); } em.persist(entA); } em.getTransaction().commit(); em.close(); System.out.println("DB population complete."); } } On Sep 4, 2014, at 4:10 AM, Tomas Kraus <tomas.kraus@xxxxxxxxxx> wrote:
|