Friday 21 December 2018

                      Spring JdbcTemplate

=======================================================================

//Employee.java

package govind.icjs.curd;

public class Employee {

private Integer id;
private String empName;
private String empAddress;
private String empEmail;
private String empDesignation;
private Float empSalary;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getEmpName() {
return empName;
}
public void setEmpName(String empName) {
this.empName = empName;
}
public String getEmpAddress() {
return empAddress;
}
public void setEmpAddress(String empAddress) {
this.empAddress = empAddress;
}
public String getEmpEmail() {
return empEmail;
}
public void setEmpEmail(String empEmail) {
this.empEmail = empEmail;
}
public String getEmpDesignation() {
return empDesignation;
}
public void setEmpDesignation(String empDesignation) {
this.empDesignation = empDesignation;
}
public Float getEmpSalary() {
return empSalary;
}
public void setEmpSalary(Float empSalary) {
this.empSalary = empSalary;
}



}


=================================================================================================================================
package govind.icjs.curd;
// EmployeeDao.java
import java.util.List;

import javax.sql.DataSource;

public interface EmployeeDao {


   public void setDataSource(DataSource ds);

   public void insertData(Integer id,String empName,String empAddress,String empEmail,String empDesignation,Float empSalary);

   public Employee getEmployee(Integer id);

   public List<Employee> getAllEmployee();

   public void delete(Integer id);

   public int update(Integer id,String emp_name,String emp_address);

}


=======================================================================================================================================
//EmployeeDaoImpl.java
============================================
package govind.icjs.curd;


import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;


public class EmployeeDaoImpl implements EmployeeDao {

private DataSource datasource;
private JdbcTemplate jdbcTemplate;

@Override
public void setDataSource(DataSource datasource) {
this.datasource=datasource;
this.jdbcTemplate=new JdbcTemplate(datasource);

}
    @Override
public void insertData(Integer id, String empName, String empAddress, String empEmail, String empDesignation,
Float empSalary) {
String sql="insert into emp_jdbctemplate(id,emp_name,emp_address,emp_email,emp_designation,emp_salary)values(?,?,?,?,?,?)";
jdbcTemplate.update(sql,new Object[]{id,empName,empAddress,empEmail,empDesignation,empSalary});
    System.out.println("Insert Data Successfully");
}

@Override
public Employee getEmployee(Integer id) {
String sql="select * from emp_jdbctemplate where id=?";
Employee emp = jdbcTemplate.queryForObject(sql, new Object[]{id},new EmployeeMapper());
return emp;

 
 
}

@Override
public List<Employee> getAllEmployee() {

String sql="select * from emp_jdbctemplate";
List<Employee> emp = jdbcTemplate.query(sql, new EmployeeMapper());
return emp;


}

@Override
public void delete(Integer id) {
String sql="delete from emp_jdbctemplate where id="+id+" ";
jdbcTemplate.update(sql);
System.out.println("Delete Data Successfully and id="+id);

}

@Override
public int update(Integer id,String emp_name,String emp_address)
    {
String sql="update emp_jdbctemplate set emp_name=?,emp_address=? where id=?";
    return jdbcTemplate.update(sql,new Object[]{emp_name,emp_address,id});
}
}


==============================================================================================================================================
//EmployeeMapper.java
======================================
package govind.icjs.curd;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;


public class EmployeeMapper implements RowMapper<Employee>{

public Employee mapRow(ResultSet rs, int rownum) throws SQLException {
    Employee e=new Employee();
e.setId(rs.getInt("id"));
e.setEmpName(rs.getString("emp_name"));
e.setEmpAddress(rs.getString("emp_address"));
e.setEmpEmail(rs.getString("emp_email"));
e.setEmpDesignation(rs.getString("emp_designation"));
e.setEmpSalary(rs.getFloat("emp_salary"));
return e;

}


}


===========================================================================================================================================
// EmployeeMain.java
=============================
package govind.icjs.curd;

import java.util.List;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class EmployeeMain {

public static void main(String[] args) {
ApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
    EmployeeDaoImpl edi = (EmployeeDaoImpl)ac.getBean("edaoimpl");

     System.out.println("-------------------Insert Data-----------------");
    edi.insertData(111,"sanjay", "ashoknagar", "sanjay@gmail.com","employee", 30000.00f);

    System.out.println("-------------------Delete Data-------------------");
        edi.delete(103);
   
       System.out.println("------------------Update Data----------------------");
    int status=edi.update(101, "harsh", "munirka");
    if(status>0)
{
System.out.println("-------Update data successfully-----");
}

else
{
System.out.println("---------Updated not Successfully------");
}


   Employee emp = edi.getEmployee(106);
   System.out.println(emp.getEmpName()+" "+emp.getEmpAddress()+" "+emp.getEmpEmail()+" "+emp.getEmpDesignation()+" "+emp.getEmpSalary());
   System.out.println("-----------------Data Retrieve successfully based on id----------");



    System.out.println("---------------------Retrieve all data------------------");
    List<Employee> l = edi.getAllEmployee();
    for(Employee e1:l)
    {
     System.out.println(e1.getId()+" "+e1.getEmpName()+" "+e1.getEmpAddress()+" "+e1.getEmpDesignation()+" "+e1.getEmpSalary());
    }
    System.out.println("------------Retrieve all data successfully--------------");



}

}


===========================================================================================================================================
applicationContext.xml
================================
<?xml version="1.0" encoding="UTF-8"?>
<beans
    xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:p="http://www.springframework.org/schema/p"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

<bean id="datasource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="org.postgresql.Driver" />
<property name="url" value="jdbc:postgresql://localhost:5432/govind" />
<property name="username" value="postgres" />
<property name="password" value="postgres" />
</bean>

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="datasource"></property>
</bean>
<bean id = "edaoimpl"
      class = "govind.icjs.curd.EmployeeDaoImpl">
      <property name = "dataSource" ref ="datasource" />
   </bean>
</beans>



  =======================================================================================================================================

required jar files
=====================
commons-logging-1.1.2.jar
org.springframework.beans.jar
org.springframework.context.jar
postgresql-9.4-1200-jdbc41.jar
spring-core-3.2.3.release.jar
spring-dao-2.0.6.jar
spring-jdbc-3.2.4.release.jar






No comments:

Post a Comment