Spring 连 JDBC

张玉龙

beans-jdbc.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" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd ">  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">    <property name="driverClassName" value="com.ibm.db2.jcc.DB2Driver"></property>    <property name="url" value="jdbc:db2://192.168.25.230:50000/JSAMPLE"></property>    <property name="username" value="zyl"></property>    <property name="password" value="123"></property>  </bean>    <bean id="tx" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">    <property name="dataSource" ref="dataSource"></property>  </bean>  <bean id="usersDao" class="jdbc.dao.IUsersDAOImpl">   <property name="dataSource" ref="dataSource"></property>  </bean>  <!--  TransactionProxyFactoryBean -->  <bean id="transProxy"         class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"       >    <property name="target" ref="usersDao"></property>    <property name="proxyTargetClass" value="true"></property>    <property name="transactionManager" ref="tx"></property>    <property name="transactionAttributes">     <props>       <prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>       <prop key="save*">PROPAGATION_REQUIRED,-Exception</prop>     </props>       </property>   </bean></beans>-----------------------package jdbc.dao;import jdbc.UsersPO;public interface IUsersDAO {public void saveUsers(UsersPO usersPO);}------------------------package jdbc.dao;import java.sql.ResultSet;import java.sql.SQLException;import java.util.ArrayList;import java.util.List;import jdbc.UsersPO;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.dao.DataAccessException;import org.springframework.jdbc.core.ResultSetExtractor;import org.springframework.jdbc.core.support.JdbcDaoSupport;public class IUsersDAOImpl extends JdbcDaoSupport implements IUsersDAO {public IUsersDAOImpl() {//BasicDataSource bds = new BasicDataSource();////bds.setDriverClassName("com.ibm.db2.jcc.DB2Driver");//bds.setUrl("jdbc:db2://192.168.25.230:50000/JSAMPLE");//bds.setUsername("zyl");//bds.setPassword("123");//// jdbcTemplate = new JdbcTemplate(bds);////tm = new DataSourceTransactionManager(bds);//td = new DefaultTransactionDefinition(//TransactionDefinition.PROPAGATION_REQUIRED);//td.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);}// 查询方法public void findAll() {List<UsersPO> result = (List<UsersPO>) getJdbcTemplate().query("select usersid,usersname,password from users",new ResultSetExtractor() {// 查询结果集public Object extractData(ResultSet rs)throws SQLException, DataAccessException {List<UsersPO> usersList = new ArrayList<UsersPO>();UsersPO usersPO = null;while (rs.next()) {usersPO = new UsersPO(rs.getLong(1), rs.getString(2), rs.getString(3), null);usersList.add(usersPO);}return usersList;}});for (UsersPO usersPO : result) {System.out.println(usersPO);}}public void saveUsers(UsersPO usersPO) {getJdbcTemplate().execute("insert into users (usersname,password) values('"+ usersPO.getUsersName() + "','"+ usersPO.getUsersPassword() + "')");}public static void main(String[] args) {ApplicationContext appContext = new ClassPathXmlApplicationContext("beans-jdbc.xml");IUsersDAOImpl daoImpl = (IUsersDAOImpl) appContext.getBean("transProxy");daoImpl.saveUsers(new UsersPO("zyl", "12311", null));daoImpl.findAll();}}---------------------------package jdbc;import java.io.Serializable;import java.util.Date;public class UsersPO implements Serializable {private Long usersID;private String usersName;private String usersPassword;private Date regDate;public UsersPO() {super();// TODO Auto-generated constructor stub}public UsersPO(Long usersID, String usersName, String usersPassword,Date regDate) {super();this.usersID = usersID;this.usersName = usersName;this.usersPassword = usersPassword;this.regDate = regDate;}public UsersPO(String usersName, String usersPassword, Date regDate) {super();this.usersName = usersName;this.usersPassword = usersPassword;this.regDate = regDate;}public Date getRegDate() {return regDate;}public Long getUsersID() {return usersID;}public String getUsersName() {return usersName;}public String getUsersPassword() {return usersPassword;}public void setRegDate(Date regDate) {this.regDate = regDate;}public void setUsersID(Long usersID) {this.usersID = usersID;}public void setUsersName(String usersName) {this.usersName = usersName;}public void setUsersPassword(String usersPassword) {this.usersPassword = usersPassword;}@Overridepublic String toString() {return "UsersPO [regDate=" + regDate + ", usersID=" + usersID+ ", usersName=" + usersName + ", usersPassword="+ usersPassword + "]";}@Overridepublic int hashCode() {final int prime = 31;int result = 1;result = prime * result + ((usersID == null) ? 0 : usersID.hashCode());result = prime * result+ ((usersName == null) ? 0 : usersName.hashCode());result = prime * result+ ((usersPassword == null) ? 0 : usersPassword.hashCode());return result;}@Overridepublic boolean equals(Object obj) {if (this == obj)return true;if (obj == null)return false;if (getClass() != obj.getClass())return false;UsersPO other = (UsersPO) obj;if (usersID == null) {if (other.usersID != null)return false;} else if (!usersID.equals(other.usersID))return false;if (usersName == null) {if (other.usersName != null)return false;} else if (!usersName.equals(other.usersName))return false;if (usersPassword == null) {if (other.usersPassword != null)return false;} else if (!usersPassword.equals(other.usersPassword))return false;return true;}}--------------------------CONNECT TO JSAMPLE USER "zyl" USING ;CREATE TABLE ZYL.USERS ( USERSID INTEGER  NOT NULL  GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1, NO CACHE ) , USERSNAME VARCHAR (10) , PASSWORD VARCHAR (10)   ) ;CONNECT RESET;CONNECT TO JSAMPLE USER "zyl" USING ;ALTER TABLE ZYL.USERS ADD COLUMN REGDATE DATE ;CONNECT RESET;------------------------------------USERSIDINTEGER4否USERSNAMEVARCHAR10是PASSWORDVARCHAR10是REGDATEDATE4是--------------------------IUsersDAOImpl输出结果:UsersPO [regDate=null, usersID=3, usersName=zyl, usersPassword=12311]