Java/Spring/PreparedStatementCallback

Материал из Java эксперт
Перейти к: навигация, поиск

Implements PreparedStatementCreator to get data from first column

   <source lang="java">
      

File: context.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:util="http://www.springframework.org/schema/util"
      xmlns:tx="http://www.springframework.org/schema/tx"
      xmlns:aop="http://www.springframework.org/schema/aop"
      xmlns:lang="http://www.springframework.org/schema/lang"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
                          http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd
                          http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd
                          http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
                          http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-2.0.xsd">
   <bean id="dataSource" class="org.apache.rumons.dbcp.BasicDataSource" destroy-method="close">
   <property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
   <property name="url" value="jdbc:hsqldb:mem:."/>
   <property name="username" value="sa"/>
   <property name="password" value=""/>
   </bean>
   <bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
       <property name="nativeJdbcExtractor" ref="nativeJdbcExtractor"/>
   </bean>
   <bean id="nativeJdbcExtractor" class="org.springframework.jdbc.support.nativejdbc.rumonsDbcpNativeJdbcExtractor"/>
   <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
       <property name="dataSource" ref="dataSource"/>
   </bean>

</beans>

File: Main.java import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.LinkedList; import java.util.List; import javax.sql.DataSource; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.dao.DataAccessException; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.PreparedStatementCallback; import org.springframework.jdbc.core.PreparedStatementCreator; class Main {

 public static void main(String args[]) throws Exception {
   ApplicationContext ac = new ClassPathXmlApplicationContext("context.xml", Main.class);
   DataSource dataSource = (DataSource) ac.getBean("dataSource");
   // DataSource mysqlDataSource = (DataSource) ac.getBean("mysqlDataSource");
   JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
   List<Long> ids;
   ids = (List<Long>) jdbcTemplate.execute(new MyPreparedStatementCreator(), new MyPreparedStatementCallback());
   System.out.println(ids);
 }

} class MyPreparedStatementCreator implements PreparedStatementCreator {

 public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
     PreparedStatement ps = connection.prepareStatement("select * from t_x where id=?");
     ps.setLong(1, 1L);
     return ps;
 }

} class MyPreparedStatementCallback implements PreparedStatementCallback {

 public Object doInPreparedStatement(PreparedStatement preparedStatement) throws SQLException, DataAccessException {
     ResultSet rs = preparedStatement.executeQuery();
     List<Long> ids = new LinkedList<Long>();
     while (rs.next()) {
         ids.add(rs.getLong(1));
     }
     rs.close();
     return ids;
 }

}


      </source>
   
  
 
  



Select Statement With PreparedStatementCallback

   <source lang="java">
      

File: context.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:util="http://www.springframework.org/schema/util"
      xmlns:tx="http://www.springframework.org/schema/tx"
      xmlns:aop="http://www.springframework.org/schema/aop"
      xmlns:lang="http://www.springframework.org/schema/lang"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
                          http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd
                          http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd
                          http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
                          http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-2.0.xsd">
   <bean id="dataSource" class="org.apache.rumons.dbcp.BasicDataSource" destroy-method="close">
   <property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
   <property name="url" value="jdbc:hsqldb:mem:."/>
   <property name="username" value="sa"/>
   <property name="password" value=""/>
   </bean>
   <bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
       <property name="nativeJdbcExtractor" ref="nativeJdbcExtractor"/>
   </bean>
   <bean id="nativeJdbcExtractor" class="org.springframework.jdbc.support.nativejdbc.rumonsDbcpNativeJdbcExtractor"/>
   <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
       <property name="dataSource" ref="dataSource"/>
   </bean>

</beans>

File: Main.java import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.LinkedList; import java.util.List; import javax.sql.DataSource; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.dao.DataAccessException; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.PreparedStatementCallback; import org.springframework.jdbc.core.PreparedStatementCreator; class Main {

 public static void main(String args[]) throws Exception {
   ApplicationContext ac = new ClassPathXmlApplicationContext("context.xml", Main.class);
   DataSource dataSource = (DataSource) ac.getBean("dataSource");
   // DataSource mysqlDataSource = (DataSource) ac.getBean("mysqlDataSource");
   JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
   List<Long> ids;
   ids = (List<Long>) jdbcTemplate.execute("select id from t_x", new MyPreparedStatementCallback());
   System.out.println(ids);
 }

} class MyPreparedStatementCallback implements PreparedStatementCallback {

 public Object doInPreparedStatement(PreparedStatement preparedStatement) throws SQLException, DataAccessException {
     ResultSet rs = preparedStatement.executeQuery();
     List<Long> ids = new LinkedList<Long>();
     while (rs.next()) {
         ids.add(rs.getLong(1));
     }
     rs.close();
     return ids;
 }

}


      </source>