Hallo, kali ini mpu-nya mau coba share ilmu lagi dengan bahasa pemrograman JAVA menggunakan Spring Hibernate sambil iseng2 maenin java lagi, Langsung aja :
Sebelum masuk ke langkah pembuatan kodenya, buat settingan project seperti gambar berikut:
Untuk aplikasi yang mpu-nya buat susunan folder project-nya src/main/java/spring_jdbc
Pertama buat terlebih dahulu main class aplikasinya, buat class
Application.java
package spring_jdbc;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
Kedua buat class database config-nya dengan nama file
DBConfig.java, susunan folder project-nya src/main/java/spring_jdbc/config
package spring_jdbc.config;
import java.util.Properties;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.orm.hibernate4.HibernateTransactionManager;
import org.springframework.orm.hibernate4.LocalSessionFactoryBean;
import org.springframework.transaction.annotation.EnableTransactionManagement;
@Configuration
@EnableTransactionManagement
public class DBConfig {
@Value("${db.driver}")
private String DB_DRIVER;
@Value("${db.password}")
private String DB_PASSWORD;
@Value("${db.url}")
private String DB_URL;
@Value("${db.username}")
private String DB_USERNAME;
@Value("${hibernate.dialect}")
private String HIBERNATE_DIALECT;
@Value("${hibernate.show_sql}")
private String HIBERNATE_SHOW_SQL;
@Value("${hibernate.hbm2ddl.auto}")
private String HIBERNATE_HBM2DDL_AUTO;
@Value("${entitymanager.packagesToScan}")
private String ENTITYMANAGER_PACKAGES_TO_SCAN;
@Bean
public DataSource dataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(DB_DRIVER);
dataSource.setUrl(DB_URL);
dataSource.setUsername(DB_USERNAME);
dataSource.setPassword(DB_PASSWORD);
return dataSource;
}
@Bean
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean();
sessionFactoryBean.setDataSource(dataSource());
sessionFactoryBean.setPackagesToScan(ENTITYMANAGER_PACKAGES_TO_SCAN);
Properties hibernateProperties = new Properties();
hibernateProperties.put("hibernate.dialect", HIBERNATE_DIALECT);
hibernateProperties.put("hibernate.show_sql", HIBERNATE_SHOW_SQL);
hibernateProperties.put("hibernate.hbm2ddl.auto", HIBERNATE_HBM2DDL_AUTO);
sessionFactoryBean.setHibernateProperties(hibernateProperties);
return sessionFactoryBean;
}
@Bean
public HibernateTransactionManager transactionManager() {
HibernateTransactionManager transactionManager = new HibernateTransactionManager();
transactionManager.setSessionFactory(sessionFactory().getObject());
return transactionManager;
}
}
Ketiga setting file
application.properties untuk koneksi database-nya, di src/main/resources
# Database
db.driver: com.mysql.jdbc.Driver
db.url: jdbc:mysql://(url_apps):(port_mysql)/nama_database
db.username: username
db.password: password
# Hibernate
hibernate.dialect: org.hibernate.dialect.MySQL5Dialect
hibernate.show_sql: true
hibernate.hbm2ddl.auto: update
entitymanager.packagesToScan: (package_main_aplikasi)
Keempat buat Controller dengan nama file
UserController.java, susunan folder project-nya src/main/java/spring_jdbc/controller
package spring_jdbc.controller;
import spring_jdbc.model.User;
import spring_jdbc.model.UserDao;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
/*
* buat mapping pemanggilan url untuk controller
*/
@Controller
@RequestMapping(value="/user")
public class UserController {
@Autowired
protected UserDao _userDao;
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi insert/create data kedalam table
*/
@RequestMapping(value="/save")
@ResponseBody
public String create(String email, String name) {
try {
User user = new User(email, name);
_userDao.save(user);
}
catch(Exception ex) {
return ex.getMessage();
}
return "User succesfully saved!";
}
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi delete data di table
*/
@RequestMapping(value="/delete")
@ResponseBody
public String delete(long id) {
try {
User user = new User(id);
_userDao.delete(user);
}
catch(Exception ex) {
return ex.getMessage();
}
return "User succesfully deleted!";
}
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi update data di table
*/
@RequestMapping(value="/update")
@ResponseBody
public String update(long id, String email, String name) {
try {
_userDao.update(id, email, name);
return "Update succesfully";
}
catch(Exception ex) {
return ex.getMessage();
}
}
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi pencarian data ID berdasarkan email
* yang di inputkan
*/
@RequestMapping(value="/get-by-email")
@ResponseBody
public String getByEmail(String email) {
String userId = null;
try {
User user = _userDao.getByEmail(email);
userId = String.valueOf(user.getId());
}
catch(Exception ex) {
return ex.getMessage();
}
return "The user id is: "+userId;
}
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi pencarian data ID berdasarkan email
* yang di inputkan dan nilai pengembaliannya berupa json
*/
@SuppressWarnings("unchecked")
@RequestMapping(value="/get-by-mail")
@ResponseBody
public List<User> getByMail(String email) {
try {
return (List<User>) _userDao.getByMail(email);
}
catch(Exception ex) {
return (List<User>) ex;
}
}
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi pencarian data secara keseluruhan
* dan nilai pengembaliannya berupa json
*/
@SuppressWarnings("unchecked")
@RequestMapping(value="/get-all")
@ResponseBody
public List<User> getAll(String id) {
try {
return _userDao.getAll();
}
catch(Exception e) {
return (List<User>) e;
}
}
/*
* mapping ini berfungsi untuk pemanggilan url
* pada aksi pencarian data secara keseluruhan
* tanpa menggunakan tanda (?) dalam pemanggilan
* variabel-nya dan nilai pengembaliannya berupa json
*/
@SuppressWarnings("unchecked")
@RequestMapping(value="/get_by_mail/{email:.+}", method=RequestMethod.GET)
@ResponseBody
public List<User> getByGender(@PathVariable("email") String email, ModelMap model) {
try {
return (List<User>) _userDao.getByMail(email);
}
catch(Exception ex) {
return (List<User>) ex;
}
}
}
Kelima buat file
User.java dan
UserDao.java, susunan folder project-nya src/main/java/spring_jdbc/model.
file
User.java berfungsi untuk men-set variabel2 yang akan di panggil oleh file
UserDao.java.
berikut file
User.java
package spring_jdbc.model;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Size;
@Entity
@Table(name="customer")
public class User {
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
private long id;
@NotNull
@Size(min = 3, max = 80)
private String email;
@NotNull
@Size(min = 2, max = 80)
private String name;
protected User() { }
/*
* buat method User dengan attribute hanya ID
* berfungsi untuk pencarian atau menampilkan informasi
* berdasarkan ID saja
*/
public User(long id) {
this.id = id;
}
/*
* buat method User dengan attribute selain ID
* berfungsi untuk input data
*/
public User(String email, String name) {
this.email = email;
this.name = name;
}
/*
* buat method id, kemudian buat method pemanggilannya
* yang mana nilai method-nya akan di kembalikan ke method pemanggilnya
*/
public void setId(long id) {
this.id = id;
}
public long getId() {
return id;
}
/*
* buat method email, kemudian buat method pemanggilannya
* yang mana nilai method-nya akan di kembalikan ke method pemanggilnya
*/
public void setEmail(String email) {
this.email = email;
}
public String getEmail() {
return email;
}
/*
* buat method name, kemudian buat method pemanggilannya
* yang mana nilai method-nya akan di kembalikan ke method pemanggilnya
*/
public void setName(String name) {
this.name = name;
}
public String getName() {
return name;
}
}
berikut file
UserDao.java
package spring_jdbc.model;
import java.util.List;
import javax.transaction.Transactional;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
@Repository
@Transactional
public class UserDao {
@Autowired
private SessionFactory _sessionFactory;
private Session getSession() {
return _sessionFactory.getCurrentSession();
}
/*
* menyimpan data berdasarkan id
*/
public void save(User user) {
getSession().save(user);
return;
}
/*
* menghapus data berdasarkan id
*/
public void delete(User user) {
getSession().delete(user);
return;
}
/*
* mengupdate data berdasarkan id
*/
public void update(long id, String email, String name) {
getSession().createQuery("UPDATE User SET email=:byEmail, name=:byName WHERE id=:byId")
.setParameter("byEmail", email)
.setParameter("byName", name)
.setParameter("byId", id)
.executeUpdate();
//getSession().update(user);
return;
}
/*
* menampilkan data berdasarkan email yang dimasukkan
* dan mengembalikan nilainya berupa string
*/
public User getByEmail(String email) {
return (User) getSession()
.createQuery("select b from User b where email = :byEmail")
.setParameter("byEmail", email)
.uniqueResult();
}
/*
* menampilkan data berdasarkan email yang dimasukkan
* dan mengembalikan nilainya berupa json
*/
@SuppressWarnings("unchecked")
public List<User> getByMail(String email) {
return getSession()
.createQuery("select b from User b where email = :byEmail")
.setParameter("byEmail", email)
.list();
}
/*
* menampilkan data secara keseluruhan dan
* mengembalikan nilainya berupa json
*/
@SuppressWarnings("unchecked")
public List<User> getAll() {
return getSession().createQuery("from User").list();
}
}
Setelah selesai membuat file2 diatas, langkah selanjutnya ketikan url berikut untuk membuat data. Jangan lupa di mysql-nya buat database-nya terlebih dahulu.
http://localhost:8080/user/save?email=chocolate@gmail.com&name=cocolatos (insert)
http://localhost:8080/user/update?id=1&email=change@gmail.com&name=strawberry (update)
http://localhost:8080/user/delete?id=1 (delete)
http://localhost:8080/user/get-all (select)
http://localhost:8080/user/get-by-mail?email=(nama_email) (select)
http://localhost:8080/user/get_by_mail/(nama_email) (select)
* (http://localhost:8080/) tergantung setting tomcat masing2
Sekian share yang mpu-nya kasih, semoga bermanfaat ^_^
