Advertisement
Guest User

sqlqry

a guest
Feb 8th, 2016
64
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 3.03 KB | None | 0 0
  1. //Entity - inner class in the Test class
  2. public static class SubEntity extends GeneralEntity {
  3.         public SubEntity() {
  4.         }
  5.  
  6. //        @QuerySqlField
  7.         private String name;
  8.  
  9.         public SubEntity(Long id,String name) {
  10.             this.setId(id);
  11.             this.name = name;
  12.         }
  13.  
  14.         public String getName() {
  15.             return name;
  16.         }
  17.  
  18.         public void setName(String name) {
  19.             this.name = name;
  20.         }
  21.  
  22.         @Override
  23.         public void writeExternal(ObjectOutput out) throws IOException {
  24.             super.writeExternal(out);
  25.             out.writeUTF(name);
  26.         }
  27.  
  28.         @Override
  29.         public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
  30.             super.readExternal(in);
  31.             name=in.readUTF();
  32.         }
  33. }
  34.  
  35. //Test:
  36.     @Test
  37.     public void gridCRUDTest() {
  38.         assertNotNull(service);
  39.         for(int i=0;i<10;i++) {
  40.             service.insert(new SubEntity(service.getNextId(), "name" + (i + 1)));
  41.         }
  42.         SqlQuery<Long,SubEntity> qry=new SqlQuery<Long, SubEntity>(SubEntity.class," name = ?");
  43.         qry.setArgs("name1");
  44.         try(QueryCursor<Cache.Entry<Long,SubEntity>> cursor=cache.query(qry)) {
  45.             Iterator<Cache.Entry<Long,SubEntity>> it=cursor.iterator();
  46.             SubEntity e=it.next().getValue();
  47.             assertNotNull(e);
  48.             System.out.println(e.getName());
  49.             assertEquals("name1",e.getName());
  50.         }
  51. }
  52. //Config:
  53. <bean id="test-cache" class="org.apache.ignite.configuration.CacheConfiguration">
  54. ...
  55. <property name="indexedTypes">
  56.             <list>
  57.                 <value>java.lang.Long</value>
  58.                 <value>ru.sberbank.oti.general.entities.GeneralEntity</value>
  59.                 <value>java.lang.Long</value>
  60.                 <value>ru.sberbank.oti.gridgain.GridTest$SubEntity</value>
  61.                 <value>java.lang.Long</value>
  62.                 <value>ru.sberbank.oti.general.entities.User</value>
  63.             </list>
  64.     </property>
  65.     <property name="queryEntities">
  66.         <list>
  67.             <bean class="org.apache.ignite.cache.QueryEntity">
  68.                         <property name="keyType" value="Long"/>
  69.                         <property name="valueType" value="ru.sberbank.oti.gridgain.GridTest$SubEntity"/>
  70.                         <property name="fields">
  71.                             <map>
  72.                                 <entry key="id" value="java.lang.Long"/>
  73.                                 <entry key="name" value="java.lang.String"/>
  74.                             </map>
  75.                         </property>
  76.  
  77.                         <property name="indexes">
  78.                             <list>
  79.                                 <bean class="org.apache.ignite.cache.QueryIndex">
  80.                                     <constructor-arg value="id" />
  81.                                 </bean>
  82.                             </list>
  83.                         </property>
  84.                     </bean>
  85.                 </list>
  86.             </property>
  87.         </bean>
  88.     </list>
  89. </property>
  90. </bean>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement