Herkese merhaba arkadaşlar bir önceki yazıda EclipseLink JPA framework üzerinde cache yönetimi konusuna giriş yapılmıştı. Bu yazıda ise Cache sisteminin iki önemli parçasından biri olan Layer1 (L1) düzeyinde cacheleme yönteminden bahsedeceğim.

EclipseLink JPA Layer1  Cache  Nedir?

EclipseLink JPA framework üzerinde iki cache sistemi vardır. Bunlar, Layer1 ve Layer2 cacheleme sistemidir. Layer1 cache sistemi EntityManager bazında tutulur. Her EntityManager kendisine ait bir içerik tutar. Bu içerik ise Entity nesnelerinden oluşan bir listedir. Yani EntityManagerFactory'den her oluşturulmuş olan EntityManager kendine ait bir içerik (context) barındırır. Bu içerikte yapılan cacheleme sistemine  Layer1 düzeyde cachleme denir. Bütün EntityManager'lara ait içeriklerin cachelendiği sisteme ise Layer2 sistemi denilir. Layer2 cacheleme sistemi EntityManagerFactory düzeyinde tutulur.

EntityManager üzerinden Native SQL çalıştırıldığı durumlarda Layer1 cache üzerinde herhangi bir güncelleme yapılmaz. Böyle durumlarda cache sisteminde Memory Leak ve benzeri sorunlar meydana gelir.

EclipseLink JPA Cache Yönetimi Örnekleri …

Eclipse üzerinde yeni bir proje açılır ve aşağıdaki gibi bir “persistence.xml” oluşturulur.

<?xml version="1.0" encoding="UTF-8"?>

<persistence version="2.0" xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">

       <persistence-unit name="Test.development.mysql" transaction-type="RESOURCE_LOCAL">

             <!-- PersistenceUnit içinde yer alacak olan tablolara ait Entity Sınıflar yazılır -->

             <class>com.Sample2</class>

             <class>com.Sample1</class>

             <!-- Veritabanı bağlantısı için gerekli olan parametreler -->

             <properties>

                    <!-- MySQL veritabanı bağlantı URL -->

                    <property name="javax.persistence.jdbc.url" value="jdbc:mysql://localhost:3306/test"/>

                    <!-- Veritabanına bağlanacak olan Username ve Password bilgileri -->

                    <property name="javax.persistence.jdbc.password" value=""/>

                    <property name="javax.persistence.jdbc.user" value=""/>

                    <property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver"/>

                    <!-- Tablo işlemleri için mod seçilir. -->

                    <!--

                           create-tables : Yukarıda belirtilen sınıflara karşılık veritabanı tarafında bir tablo yok ise yaratılır.

                           none : Tablo yaratılmasını engeller. Herhangi bir tablo yaratma veya değiştirme işlemi yapılmaz.

                           drop-and-create-tables : Varolan tabloları drop eder ve yeniden create eder.

                     -->

                    <property name="eclipselink.ddl-generation" value="create-tables" /> <!-- none / create-tables / drop-and-create-tables -->

                    <property name="eclipselink.ddl-generation.output-mode" value="database" />

                    <!-- Console ekranında işletilmiş olan SQL cümleleri loglanır ve gösterilir. -->

             <property name="eclipselink.logging.level.sql" value="FINE"/>

                    <property name="eclipselink.logging.parameters" value="true"/>

             </properties>

       </persistence-unit>

</persistence>

Ardından aşağıdaki gibi bir Entity hazırlanır.

@SuppressWarnings("serial")

// Entity etiketi ile birlikte hazırlanmış olan sınıfın veritabanı tarafında bir tablo olarak yaratılacağı belirtilir.

@Entity

// Veritabanı tablosunun ismi ve bulunduğu veritabanı ismi belirtilir.

@Table(name="Sample1", schema="test")

public class Sample1 implements Serializable{

       // Id etiketiyle birlikte bu değişkenin primary key alanı olacağı belirtilir.

       @Id

       // GeneratedValue etiketi ile birlikte primary key olan alanın artış değeri ve sequence'i verilir.

       // IDENTITY ile primary key alanın birer birer artacağını temsil edilir.

       @GeneratedValue(strategy=GenerationType.AUTO)

       // Column etiketi ile birlikte sütuna ait gerekli ayarlamalar yapılabilir.

       @Column(name="id")

       private long id;

       @Column(name="name")

       private String name;

       @Column(name="age")

       private int age;

       public long getId() {

             return id;

       }

       public void setId(long id) {

             this.id = id;

       }

       public String getName() {

             retun name;

       }

       public void setName(String name) {

             this.name = name;

       }

       public int getAge() {

             return age;

       }

       public void setAge(int age) {

             this.age = age;

       }

}

Yukarıda yer alan  “Sample1”  adlı tabloya ait birden fazla kayıt oluşturulur ve bu kayıtlar EntityManager context'i içine bir “SELECT” sorgusu ile alınır ve Layer1 düzeyde cachelenir. 

Not : Layer1 düzeydeki cachelenmiş nesneleri temizlemek için “EntityManager.clear()” metodu çağrılır ve EntityManager içeriği temizlenmiş olur.

İlk örnekte EntityManaher context'inde bulunan Sample1 nesnelerinden ilki alınıp üzerinde güncelleme yapılır. Ardından Layer1 düzeyde cache temizlenmeden, güncellenmiş olan kayıt sorgulanır. Sorgulama sonucunda güncellenmiş olan kaydın cacheden okunup geldiği anlaşılır. Herhangi bir “commit” işlemi yapılmadığı halde kayıt güncellenmiş olarak değerlendirilir. Böylece gereksiz yere sürekli veritabanı ile işlem yapılmamış olunacaktır.

// EntityManagerFactory oluşturulur.

EntityManagerFactory factory = Persistence.createEntityManagerFactory("Test.development.mysql");

// EntityManagerFactory ile EntityManager oluşturulur.

EntityManager em = factory.createEntityManager();

// Sample1 tablosuna ait bütün kayıtlar listelenir.

List<Sample1> list =  em.createQuery(em.getCriteriaBuilder().createQuery(Sample1.class)).getResultList();

for (Iterator<Sample1> iterator = list.iterator(); iterator.hasNext();) {

                Sample1 object = (Sample1) iterator.next();

                System.out.println(object.getId());

}

// Listede yer alan ilk Sample1 nesnesi üzerinde güncelleme yapılır.

((Sample1)list.get(0)).setName("DENEME ISMI");

// "merge" metoduyla birlikte ilgili nesne EntityManager context'ine güncellenmiş olarak yerleştirilir.

// Böylece güncellenmiş olan kayıt veritabanına yansıtılmaz. Çünkü herhangi bir commit işlemi yapılmamıştır.

// Güncellenmiş olan kayıt cache üzerindedir.

em.merge(list.get(0));

// "find" metoduyla EntityManager üzerinden kayıt bulma işlemi yapıldığında,

// güncellenmiş kayıt cache'den okunur ve veritabanına gidilmemiş olunur.

Sample1 sample1 = rm2.find(Sample1.class, list.get(0).getId());

System.out.println(sample1.getName());

Sonuç :

İkinci örnekte Layer1 cache üzerinde bulunan kayıtlar temizlenir ve güncellenmiş olan kayıt tekrar sorgulandığında kaydın eski bilgilerle geldiği görülecektir. ”commit” işlemi yapılmadığı için kayıt kalıcı olarak veritabanına hiçbir zaman yansıtılmamıştır. Layer1 Cache temizlendiği için ilgili kayıt Layer2 cacheden alınıp getirilecektir. Eğerki Layer2 cache'de temizlenmişse kayıt direkt veritabanından SQL işletilerek getirilecektir.

// EntityManagerFactory oluşturulur.

EntityManagerFactory factory = Persistence.createEntityManagerFactory("Test.development.mysql");

// EntityManagerFactory ile EntityManager oluşturulur.

EntityManager em = factory.createEntityManager();

// Sample1 tablosuna ait bütün kayıtlar listelenir.

List<Sample1> list = rm2.createQuery(rm2.getCriteriaBuilder().createQuery(Sample1.class)).getResultList();

 for (Iterator<Sample1> iterator = list.iterator(); iterator.hasNext();) {

                   Sample1 object = (Sample1) iterator.next();

                   System.out.println(object.getId());

}

// Listede yer alan ilk Sample1 nesnesi üzerinde güncelleme yapılır.

 ((Sample1)list.get(0)).setName("DENEME ISMI");

// "merge" metoduyla birlikte ilgili nesne EntityManager context'ine güncellenmiş olarak yerleştirilir.

// Böylece güncellenmiş olan kayıt veritabanına yansıtılmaz. Çünkü herhangi bir commit işlemi yapılmamıştır.

// Güncellenmiş olan kayıt cache üzerindedir.

rm2.merge(list.get(0));

// Layer1 cachedeki tüm nesneler temizlenir.Layer1 cache tamamen silinmiş olur.

rm2.clear();

// "find" metoduyla EntityManager üzerinden kayıt bulma işlemi yapıldığında,

// güncellenmiş kayıt cache'den okunur ve veritabanına gidilmemiş olunur.

Sample1 sample1 = rm2.find(Sample1.class, list.get(0).getId());

System.out.println(sample1.getName());

Sonuç :

Eğerki Layer1 ve Layer2 cachelerinden bütün nesneler temizlenmiş olsaydı. Aşağıdaki gibi SQL çalıştırılıp aranan kayıt veritabanından getirelecektir. Diğer sonuçlar incelenirse herhangi bir SQL çalıştırılmadığı ve cache üzerinden çalışıldığı görülecektir. 

Evet  Layer1  cache ile ilgili şimdilik bahsedeceklerim bunlardan ibaret. Umarım yararlı ve zevkli bir bir yazı olmuştur. Bir sonraki makalemde görüşmek üzere …

Batuhan Düzgün

Bilgisayar Mühendisi

Endüstri Mühendisi