JBoss Data Grid(infinispan) 에서 PostgreSQL 로 Persistence Cache Store 사용해 보기

JdbcStoreTest.xml 파일에 캐시로더와 캐시스토어로 stringKeyedJdbcStore 를 사용하며 PostgreSQL DB 에 저장하고 로드하게 됩니다.

<?xml version="1.0" encoding="UTF-8"?>
<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:infinispan:config:6.0 http://www.infinispan.org/schemas/infinispan-config-6.0.xsd
                            urn:infinispan:config:jdbc:6.0 http://www.infinispan.org/schemas/infinispan-cachestore-jdbc-config-6.0.xsd"
xmlns="urn:infinispan:config:6.0">
<namedCache name="persistentCache">
<persistence passivation="false">
<stringKeyedJdbcStore xmlns="urn:infinispan:config:jdbc:6.0"
fetchPersistentState="false" ignoreModifications="false"
purgeOnStartup="false">
<connectionPool connectionUrl="jdbc:postgresql://localhost:5432/postgres"
driverClass="org.postgresql.Driver" username="infinispan" password="infinispan" ></connectionPool>
<stringKeyedTable prefix="ISPN_STRING_TABLE"
createOnStart="true" dropOnExit="false">
<idColumn name="ID_COLUMN" type="VARCHAR(255)" ></idColumn>
<dataColumn name="DATA_COLUMN" type="bytea" ></dataColumn>
<timestampColumn name="TIMESTAMP_COLUMN" type="BIGINT" ></timestampColumn>
</stringKeyedTable>
</stringKeyedJdbcStore>
</persistence>
<transaction
transactionManagerLookupClass="org.infinispan.transaction.lookup.DummyTransactionManagerLookup"
transactionMode="TRANSACTIONAL" lockingMode="OPTIMISTIC" ></transaction>
</namedCache>
</infinispan>

코드의 내용은 “JdbcStoreTest.xml” 파일에서 “persistentCache”에 대한 정의 내용을 읽고 stringKeyedJdbcStore 로 정의된 PostgreSQL 에 저장된 데이터를 로딩하게 됩니다.
최초 실행 시에는 데이터베이스에 저장된 데이터가 없기 때문에 “cache.get()” 실행 시 “null” 이 출력 됩니다. 다음 로직이 1~100 까지 “cache.put”을 수행하게 되고
cache 에 데이터가 저장됨과 동시에 JDBC 를 통하여 PostgreSQL DB 에도 데이터가 저장되게 됩니다.
애플리케이션을 두 번째 실행하게 되면 첫 번째 실행 시 DB 캐시 스토어에 저장되었던 데이터가 출력되어 최초 “null” 값이 아닌 “value99” 형태로 순차적으로 값이 출력됩니다.

JdbcStoreTest.java 코드는 아래와 같습니다.

package infinispan.sample;

import org.infinispan.Cache;
import org.infinispan.manager.DefaultCacheManager;

public class JdbcStoreTest {
public static void main (String args []) throws Exception {
Cache cache = new DefaultCacheManager ( "JdbcStoreTest.xml").getCache("persistentCache");
for (int i = 1; i <= 100; i++) {
     System.out.println ( "Key ="+ java.lang.Integer.toString (i) + ", Value ="+ cache.get (java.lang.Integer.toString (i)));
}

for (int i=1; i<=100; i++) {
     cache.put (java.lang.Integer.toString (i), "value"+ java.lang.Integer.toString (i));
}
}
}

&#91;/code&#93;
&#91;/av_textblock&#93;
&#91;/av_one_full&#93;

&#91;av_one_full first min_height='' vertical_alignment='' space='' custom_margin='' margin='0px' padding='0px' border='' border_color='' radius='0px' background_color='' src='' background_position='top left' background_repeat='no-repeat' animation='' mobile_display=''&#93;

&#91;av_heading tag='h3' padding='10' heading='4. 작성된 애플리케이션 실행하기 ' color='' style='' custom_font='' size='' subheading_active='' subheading_size='15' custom_class='' admin_preview_bg=''&#93;&#91;/av_heading&#93;

&#91;av_heading heading=' 4-1. Eclipse 에서 실행하기' tag='h4' style='' size='' subheading_active='' subheading_size='15' padding='10' color='' custom_font='' admin_preview_bg=''&#93;&#91;/av_heading&#93;

&#91;av_textblock size='' font_color='' color='' admin_preview_bg=''&#93;
JdbcStoreTest 클래스를 Java Application 으로 실행합니다.

&#91;code language="bash"&#93;

3월 17, 2014 10:24:15 오후 org.infinispan.factories.GlobalComponentRegistry start
INFO: ISPN000128: Infinispan version: Infinispan 'Infinium' 6.0.1.Final
3월 17, 2014 10:24:16 오후 com.mchange.v2.log.MLog <clinit>
... 중략 
3월 17, 2014 10:24:17 오후 org.infinispan.jmx.CacheJmxRegistration start
INFO: ISPN000031: MBeans were successfully registered to the platform MBean server.
Key =1, Value =value1
Key =2, Value =value2
... 중략