Java JSF Hibernate ile CRUD İşlemleri(Ekle,Sil,Güncelle ve Listele)

Java JSF Hibernate ile CRUD İşlemleri(Ekle,Sil,Güncelle ve Listele)

Hibernate ile CRUD(Temel Veri Tabanı) İşlemleri

Gerekenler

1 ) JSF( Java Server Faces) üzerinde Spring Hibernate entegre etmiştik. (Yazıyı Oku)

2 ) Sonra bu  proje üzerinde Hibernate Tablo Entity sınıfları üretmeyi anlatmıştım.(Yazıyı Oku)

1 numaralı yazıdan hazır projeyi indirip üzerine 2 numaralı derse göre hibernate Tablo Entity oluşturabilirsiniz.

 

Hibernate CRUD İşlemleri(Yapılan Örnek)

# Project Name      : Hello Jsf
# Hibernate Version : 5.2.10.Final
# Spring Version    : 4.3.10.RELEASE
# Java Version      : 1.8 
# Dynamic Web       : 3.1
# Oracle DB         : 11G

Örneğimizde  veritabanında örnek tablom (ZZ_ATAKAN_PERSON) tablosu üzerinde veri listele, veri güncelle, veri sil ve veri ekle işlemleri yaptım.

1 ) hellojsf/person.xhtml (İlk olarak verilerin listelenmesi)

Tablo ile veriler çekildi
Tablo ile veriler çekildi

2 ) Silme Örneği (ID = 109  )

Silinecek satır belirlendi
Silinecek satır belirlendi

Silme işlemi sonrası tablonun görünümü(109 ID numaralı satır silindi)

Silme işlemi tamamlandı
Silme işlemi tamamlandı

3 ) Güncelleme Örneği (110 ID numaralı satır)

Güncellleme yapılacak satır seçildi
Güncellleme yapılacak satır seçildi

Güncelleme Örneği (Satır güncellenmek üzere aktif oldu )

Güncelleme işlemi başlatıldı
Güncelleme işlemi başlatıldı

Güncelleme Örneği(110 ID numaralı satır değerleri değiştirildi)

Güncelleme için değer değiştirildi
Güncelleme için değer değiştirildi

Güncelleme işlemi tamamlandı(110 ID Numaralı satır)

Güncelleme uygulandı
Güncelleme uygulandı

4 ) Satır Ekleme İşlemi

Bunun için form dolduruldu ve btnAddPerson butonu çalıştırıldı.(Altta hazırladığım örnek veri ekleme formu)

Kayıt ekleme formu
Kayıt ekleme formu

Veri Ekleme sonrası tablonun son hali (115 ID Numaralı satır eklendi )

Kayıt ekleme işlemi tamamlandı
Kayıt ekleme işlemi tamamlandı

Gördüğünüz gibi örnek sitede hibernate @Entity model sınıfı kullanılarak temel veri tabanı işlemleri yapıldı. Şimdi nasıl yaptığımıza bakalım.

 

Hibernate ile Veri Tabanı İşlemleri Kod ve Açıklamalar

Öncelikle ben örneğimde Generic Dao implementi kullandım.Resimde görüldüğü gibi Generic Dao sınıfında tüm dao sınıflarımda ortak olarak kullanılacak metodları Generic olarak oluşturdum. Bu sayede yeni DAOlar oluşturduğumuz zaman temel veritabanı işlemlerini tekrar tekrar yazmamıza gerek kalmayacak.

Hibernate Generic Dao kullanımı
Hibernate Generic Dao kullanımı

1 ) Dao ve Veri Bağlantıları Kısmı

GenericDao

package com.atakancoban.dao.base;
import java.io.Serializable;
import java.util.List;
public interface GenericDao<T extends Serializable> {
	long countAll();
	List<T> getAll();
	Serializable save(T t);
	void delete(T t);
	void update(T t);
	void saveOrUpdate(T t);
	void saveOrUpdate(List<T> list);
	void flushAndClear();
	void applyChanges();
	List<T> getOrderedAsc(String propertyName);
	List<T> getOrderedDesc(String propertyName);
}

GenericDaoImpl

package com.atakancoban.dao.base;

import java.io.Serializable;
import java.util.List;

import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projections;
import org.springframework.stereotype.Repository;

@Repository
public abstract class GenericDaoImpl<T extends Serializable> implements Serializable, GenericDao<T> {

	private static final long serialVersionUID = 1L;

	private Class<T> persistentClass;
	private SessionFactory sessionFactory;

	public GenericDaoImpl(Class<T> persistentClass) {
		this.persistentClass = persistentClass;
	}

	@Override
	public long countAll() {
		return getRowCount(getAllRecordsCriteria());
	}

	@SuppressWarnings("unchecked")
	@Override
	public List<T> getAll() {
		List<T> list = getAllRecordsCriteria().list();
		System.out.println(persistentClass.getSimpleName() + " getAll() success");
		return list;
	}

	@Override
	public Serializable save(T t) {
		Serializable serializable = getCurrentSession().save(t);

		System.out.println(persistentClass.getSimpleName() + " save() success");
		return serializable;
	}

	@Override
	public void update(T t) {
		getCurrentSession().update(t);

		System.out.println(persistentClass.getSimpleName() + " update() success");
	}

	@Override
	public void saveOrUpdate(T t) {
		getCurrentSession().saveOrUpdate(t);
		System.out.println(persistentClass.getSimpleName() + " saveOrUpdate() success");
	}

	@Override
	public void saveOrUpdate(List<T> list) {
		getCurrentSession().saveOrUpdate(list);
		System.out.println(persistentClass.getSimpleName() + " saveOrUpdate(list) success");
	}

	@Override
	public void delete(T t) {
		getCurrentSession().delete(t);
		System.out.println(persistentClass.getSimpleName() + " delete() success");
	}

	@SuppressWarnings("unchecked")
	@Override
	public List<T> getOrderedAsc(String propertyName) {
		return getAllRecordsCriteria().addOrder(Order.asc(propertyName)).list();
	}

	@SuppressWarnings("unchecked")
	@Override
	public List<T> getOrderedDesc(String propertyName) {
		return getAllRecordsCriteria().addOrder(Order.desc(propertyName)).list();
	}

	protected long getRowCount(Criteria criteria) {
		long rowCount = (Long) criteria.setProjection(Projections.rowCount()).list().get(0);
		return rowCount;
	}

	protected Criteria getAllRecordsCriteria() {
		Criteria criteria = getCurrentSession().createCriteria(getPersistentClass());
		return criteria;
	}

	public Class<T> getPersistentClass() {
		return persistentClass;
	}

	protected void setPersistentClass(final Class<T> persistentClass) {
		this.persistentClass = persistentClass;
	}

	public void setSessionFactory(SessionFactory sessionFactory) {
		this.sessionFactory = sessionFactory;
	}

	protected SessionFactory getSessionFactory() {
		return sessionFactory;
	}

	protected Session getCurrentSession() {
		return getSessionFactory().getCurrentSession();
	}

	@Override
	public void flushAndClear() {
		getCurrentSession().flush();
		getCurrentSession().clear();
	}

	@Override
	public void applyChanges() {
		getCurrentSession().flush();
	}

}

Önceki yazıda Hibernate Tools ile Oluşturduğum @Entity (Yazıyı Oku)

ZzAtakanPerson (Tablo Entitiy)

package com.atakancoban.orm;
// Generated Aug 24, 2017 3:28:08 PM by Hibernate Tools 5.2.0.Beta1

import java.math.BigDecimal;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

/**
 * ZzAtakanPerson generated by hbm2java
 */
@Entity
@Table(name = "ZZ_ATAKAN_PERSON", schema = "FCBSADM")
public class ZzAtakanPerson implements java.io.Serializable {

	private BigDecimal personId;
	private String lastname;
	private String firstname;
	private String address;
	private String city;
	private String job;

	public ZzAtakanPerson() {
	}

	public ZzAtakanPerson(BigDecimal personId) {
		this.personId = personId;
	}

	public ZzAtakanPerson(BigDecimal personId, String lastname, String firstname, String address, String city,
			String job) {
		this.personId = personId;
		this.lastname = lastname;
		this.firstname = firstname;
		this.address = address;
		this.city = city;
		this.job = job;
	}

	@Id

	@Column(name = "PERSON_ID", unique = true, nullable = false, precision = 22, scale = 0)
	public BigDecimal getPersonId() {
		return this.personId;
	}

	public void setPersonId(BigDecimal personId) {
		this.personId = personId;
	}

	@Column(name = "LASTNAME", length = 30)
	public String getLastname() {
		return this.lastname;
	}

	public void setLastname(String lastname) {
		this.lastname = lastname;
	}

	@Column(name = "FIRSTNAME", length = 30)
	public String getFirstname() {
		return this.firstname;
	}

	public void setFirstname(String firstname) {
		this.firstname = firstname;
	}

	@Column(name = "ADDRESS", length = 200)
	public String getAddress() {
		return this.address;
	}

	public void setAddress(String address) {
		this.address = address;
	}

	@Column(name = "CITY", length = 100)
	public String getCity() {
		return this.city;
	}

	public void setCity(String city) {
		this.city = city;
	}

	@Column(name = "JOB", length = 100)
	public String getJob() {
		return this.job;
	}

	public void setJob(String job) {
		this.job = job;
	}

}

 

Veri Tabanı işlemlerimi yapmak için PersonDao isminde bir dao oluşturdum ve bu dao ZzAtakanPerson tablosu için oluştu yani bu tablo ile ilgili ekleme silme güncelleme gibi işlemleri PersonDao üzerinden yapacağım. PersonDao sınıfımda GenericDao sınıfından extends olduğu için generic dao içindeki save(),update() gibi metodlarıma buradan ulaşacağım.Kod tekrarı yapmama gerek yok.

PersonDao

package com.atakancoban.dao;
import com.atakancoban.dao.base.GenericDao;
import com.atakancoban.orm.ZzAtakanPerson;
public interface PersonDao extends GenericDao<ZzAtakanPerson> {

}

PersonDaoImpl

package com.atakancoban.dao;

import java.io.Serializable;

import org.springframework.stereotype.Repository;

import com.atakancoban.dao.base.GenericDaoImpl;
import com.atakancoban.orm.ZzAtakanPerson;

@Repository("personDao")
public class PersonDaoImpl extends GenericDaoImpl<ZzAtakanPerson> implements PersonDao, Serializable {

	private static final long serialVersionUID = 1036158609629705297L;

	public PersonDaoImpl() {
		super(ZzAtakanPerson.class);
	}

}

2 ) Hibernate Config (Connection bilgileri)

testcon.xml

Burada @Entity sınıfımızı <mapping class="com.atakancoban.orm.ZzAtakanPerson" />
 sessionFactory içinde hibernate ile bağlıyoruz.
<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
	<session-factory name="sessionFactory">
		<property name="dialect">org.hibernate.dialect.Oracle10gDialect</property>
		<property name="connection.driver_class">oracle.jdbc.OracleDriver</property>
		<property name="connection.url">jdbc:oracle:thin:@İPADRESİ:1521:SID</property>
		<property name="connection.username">USERNAME</property>
		<property name="connection.password">PASSWORD</property>
		<property name="hibernate.connection.provider_class">org.hibernate.c3p0.internal.C3P0ConnectionProvider</property>
		<property name="hibernate.c3p0.acquire_increment">1</property>
		<property name="hibernate.c3p0.idle_test_period">0</property>
		<property name="hibernate.c3p0.min_size">1</property>
		<property name="hibernate.c3p0.max_size">15</property>
		<property name="hibernate.c3p0.timeout">0</property>
		<property name="show_sql">true</property>
		<property name="query.substitutions">true 1, false 0, yes 'Y', no 'N'</property>

		<mapping class="com.atakancoban.orm.ZzAtakanPerson" />

	</session-factory>

</hibernate-configuration>

3 ) Beans Xml ile İlişkilendirme Kısmı

beans-atakan-coban.xml

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd">


	<bean id="genericDao" class="com.atakancoban.dao.base.GenericDaoImpl" abstract="true">
		<property name="sessionFactory" ref="sessionFactory" />
	</bean>

	<bean id="personDao" class="com.atakancoban.dao.PersonDaoImpl" parent="genericDao" />

	<bean id="carDao" name="carDao" class="com.atakancoban.dao.CarDaoImpl">
		<property name="sessionFactory" ref="sessionFactory" />
	</bean>

</beans>

Dao sınıflarında interface ve implement edilmiş bir sınıf gördük. Spring tarafından Dependency Injection özelliği ile buradaki xml kısmında Dao ve DaoImpl sınıflarını tanıtıyoruz.<property> şeklinde ise @Autowired şeklinde çağırıldı anda setter olarak gönderilecek değişkeni gönderebiliyoruz.Detaylı anlatalım

beans içindeki genericDao tanımı burada bir yerden

@Autowired
GenericDao genericdao;

Şeklinde çağırıldığında beans xmldeki ilişkisine göre genericDaoImp metodlarını çağırabilir durumda geliyor.<property> olarak verilen session factory de o sınıfe gönderiliyor. Bu sayede her dao için session yollamamıza gerek kalmıyor.Dependency Injection ile metodu çalışmaya hazır halde sınıfımızı alıyoruz. PersonDao beans xmlde parent özelliğine genericDao yazdık metodlara ve sessiona ulaşıyoruz.

Ben örneğimde PersonDao ile çalıştığım için PersonService sınıfımda bu şekilde çağırdım

@Autowired
PersonDao personDao;
Bu sayede generic daodaki metodlara ve sessiona ulaştım.

4 ) Service ve Transactional Kısmı

PersonService

package com.atakancoban.service;

import java.util.List;

import com.atakancoban.orm.ZzAtakanPerson;

public interface PersonService {
	
	 List<ZzAtakanPerson> getPersonList() throws Exception;
	
	 void deletePerson(ZzAtakanPerson entity) throws Exception;
	
	 void updatePerson(ZzAtakanPerson entity) throws Exception;
	
	 void addPerson(ZzAtakanPerson entity) throws Exception;
	
	
}

Burada @Transactional(readOnly = true) annotationu bir metodun başında belirtmediğim sürece o metodun sadece veri çekeceğini belirtiyor.Gereksiz yere rollback yapılacak gibi transaction açmaya gerek yok.

Rollback(örneğin veri eklenirken hata oluştu birazı eklendi eski hale dönme işlemi diyebiliriz.) gereken metodlarda
@Transactional(rollbackFor = Exception.class, readOnly = false) 
Şeklinde annotation belirterek veritabanına ekleme vs işlemlerde hata oluşmamışsa işlemi uygulamasını sağladım.

PersonServiceImpl

package com.atakancoban.service;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.atakancoban.dao.PersonDao;
import com.atakancoban.orm.ZzAtakanPerson;

@Service("personService")
@Transactional(readOnly = true)
public class PersonServiceImpl implements PersonService {

	@Autowired
	private PersonDao personDao;

	@Override
	public List<ZzAtakanPerson> getPersonList() throws Exception {
		return personDao.getOrderedAsc("personId");
	}

	public PersonDao getPersonDao() {
		return personDao;
	}

	public void setPersonDao(PersonDao personDao) {
		this.personDao = personDao;
	}

	@Transactional(rollbackFor = Exception.class, readOnly = false)
	@Override
	public void deletePerson(ZzAtakanPerson entity) throws Exception {
		personDao.delete(entity);
		personDao.flushAndClear();
	}

	@Transactional(rollbackFor = Exception.class, readOnly = false)
	@Override
	public void updatePerson(ZzAtakanPerson entity) throws Exception {
		personDao.update(entity);
		personDao.flushAndClear();

	}

	@Transactional(rollbackFor = Exception.class, readOnly = false)
	@Override
	public void addPerson(ZzAtakanPerson entity) throws Exception {

		personDao.save(entity);
		personDao.flushAndClear();
	}

}

5 ) Bean ve Xhtml Kısmı

Person Xhtml

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" xmlns:ui="http://java.sun.com/jsf/facelets" xmlns:f="http://java.sun.com/jsf/core" xmlns:h="http://java.sun.com/jsf/html" xmlns:p="http://primefaces.org/ui">

<h:head></h:head>
<body>


	<h:form id="form">
		<p:dataTable id="dtPerson" value="#{personBean.listPersonEntity}" var="person" editable="true" paginator="true" paginatorPosition="bottom" rows="8" paginatorTemplate="{CurrentPageReport} {FirstPageLink} {PreviousPageLink} {PageLinks} {NextPageLink} {LastPageLink} {RowsPerPageDropdown}">


			<p:ajax event="rowEdit" listener="#{personBean.onRowEdit}" update=":form:dtPerson" />


			<p:column headerText="Person ID" sortBy="#{person.personId}" filterBy="#{person.personId}">
				<h:outputText value="#{person.personId}" />
			</p:column>

			<p:column headerText="First Name">
				<p:cellEditor>
					<f:facet name="output">
						<h:outputText value="#{person.firstname}" />
					</f:facet>
					<f:facet name="input">
						<p:inputText value="#{person.firstname}" style="width:90%" />
					</f:facet>
				</p:cellEditor>

			</p:column>

			<p:column headerText="Last Name">

				<p:cellEditor>
					<f:facet name="output">
						<h:outputText value="#{person.lastname}" />
					</f:facet>
					<f:facet name="input">
						<p:inputText value="#{person.lastname}" style="width:90%" />
					</f:facet>
				</p:cellEditor>


			</p:column>

			<p:column headerText="Job">

				<p:cellEditor>
					<f:facet name="output">
						<h:outputText value="#{person.job}" />
					</f:facet>
					<f:facet name="input">
						<p:inputText value="#{person.job}" style="width:90%" />
					</f:facet>
				</p:cellEditor>


			</p:column>

			<p:column headerText="City">

				<p:cellEditor>
					<f:facet name="output">
						<h:outputText value="#{person.city}" />
					</f:facet>
					<f:facet name="input">
						<p:inputText value="#{person.city}" style="width:90%" />
					</f:facet>
				</p:cellEditor>


			</p:column>

			<p:column headerText="Adress">

				<p:cellEditor>
					<f:facet name="output">
						<h:outputText value="#{person.address}" />
					</f:facet>
					<f:facet name="input">
						<p:inputText value="#{person.address}" style="width:90%" />
					</f:facet>
				</p:cellEditor>

			</p:column>

			<p:column headerText="Delete">
				<p:commandButton value="Delete" actionListener="#{personBean.onDelete(person)}" update=":form:dtPerson" />
			</p:column>


			<p:column headerText="Update">
				<p:rowEditor />
			</p:column>

		</p:dataTable>

		<p:panelGrid columns="1">


			<p:inputText placeholder="Firstname" value="#{personBean.firstname}" />

			<p:inputText placeholder="Lastname" value="#{personBean.lastname}" />

			<p:inputText placeholder="Job" value="#{personBean.job}" />

			<p:inputText placeholder="City" value="#{personBean.city}" />

			<p:inputText placeholder="Adress" value="#{personBean.adress}" />

		</p:panelGrid>

		<p:commandButton value="btnAddPerson" update=":form:dtPerson" actionListener="#{personBean.onAddPerson()}" />




	</h:form>
</body>
</html>

Bu sayfasında datatable oluşturdum.value=”#{personBean.listPersonEntity}”  veritabanından çektiğim verileri burada listeledim.loadTable() metodu ile bean > service > dao sıralaması ile verinin ekrana gelmesini sağladım

Bean sınıfımda oluşturduğum actionListener=”#{personBean.onDelete(person)}” metodu ile bean > service > dao sırası ile çağırılmasını sağladım ve silme işlemi yaptım.

Güncelleme işlemi için <p:rowEditor /> kullandım. Bu araç değişikliği onayla (tik ikonu) basıldığında

<p:ajax event=”rowEdit” listener=”#{personBean.onRowEdit}” update=şeklinde event çalıştırır.Burada onRowEdit metodum benim Bean> Service >Dao şeklinde veritabanında güncelleme işlemini yaptırmamı sağladı.

Peki bu update ne oluyor ?

Primefaces araçları arkaplanda yapılan değişikliği göstermek için update edilmelidir.

Araçlar update edilmezse metod çalışıyor ama veriler değişmiyor diyebilirsiniz..

Update için aşağıdaki formatta istediğiniz aracı update edebilirsiniz.person xhtml içinde update nerelerde yapılmış bakmayı unutmayın

update=”:formAdı:araçID

PersonBean

xhtml tarafından erişlen sayfamız beandir.Xhtml aracı db işlemi için Bean > Service > Dao sıralamasında metod zinciri çalıştırır.

package com.atakancoban.bean;

import java.io.Serializable;
import java.math.BigDecimal;
import java.util.List;

import javax.annotation.PostConstruct;
import javax.faces.bean.ManagedBean;
import javax.faces.bean.ManagedProperty;

import org.primefaces.event.RowEditEvent;
import org.springframework.web.context.annotation.SessionScope;

import com.atakancoban.orm.ZzAtakanPerson;
import com.atakancoban.service.PersonService;

@ManagedBean(name = "personBean")
@SessionScope
public class PersonBean implements Serializable {

	private static final long serialVersionUID = -8162090623891464980L;

	private List<ZzAtakanPerson> listPersonEntity;

	@ManagedProperty(value = "#{personService}")
	private PersonService personService;

	private String firstname, lastname, job, city, adress;

	@PostConstruct
	public void init() {
		try {

			loadTable();

		} catch (Exception e) {
			System.out.println("init() Error. " + e.getMessage());
			e.printStackTrace();
		}
	}

	public void onDelete(ZzAtakanPerson entity) {
		try {

			personService.deletePerson(entity);
			System.out.println(entity.getPersonId().longValue());
			loadTable();

		} catch (Exception e) {
			System.out.println("onDelete() Error. " + e.getMessage());
			e.printStackTrace();

		}
	}

	public void onRowEdit(RowEditEvent event) {
		try {

			ZzAtakanPerson entity = (ZzAtakanPerson) event.getObject();
			personService.updatePerson(entity);
			loadTable();
		} catch (Exception e) {
			System.out.println("onRowEdit() Error. " + e.getMessage());
			e.printStackTrace();
		}
	}

	public void onAddPerson() {
		try {

			ZzAtakanPerson entity = new ZzAtakanPerson();
			entity.setFirstname(firstname);
			entity.setLastname(lastname);
			entity.setJob(job);
			entity.setCity(city);
			entity.setAddress(adress);
			entity.setPersonId(new BigDecimal(00));

			personService.addPerson(entity);
			loadTable();

		} catch (Exception e) {
			System.out.println("onAddPerson() Error. " + e.getMessage());
			e.printStackTrace();
		}

	}

	public void loadTable() throws Exception {

		listPersonEntity = personService.getPersonList();
	}
// *****Getter - Setter******
}

Projenin kaynak kodlarını github hesabımdan indirebilirsiniz

Jsf,Spring Framework ve Hibernate ile uzmanlık gerektiren sorular için > Şükrü Çakmak

Bir Cevap Yazın

E-posta hesabınız yayımlanmayacak. Gerekli alanlar * ile işaretlenmişlerdir