package Cuiyw.Spring.Dao;import java.sql.ResultSet;
import java.sql.SQLException;import org.springframework.jdbc.object.MappingSqlQuery;import Cuiyw.Spring.Model.User;public class UserMappingSqlQuery extends MappingSqlQuery {@Overrideprotected Object mapRow(ResultSet rs, int rowNum) throws SQLException {// TODO Auto-generated method stubUser user=new User();user.setUserId((Integer)rs.getInt("id"));user.setName((String)rs.getString("name"));user.setMoney((Float)rs.getFloat("money"));return user;}}

    public List<User> QueryAllUser() {String sql="select id,name,money from tb_user where name=?";UserMappingSqlQuery userQuery=new UserMappingSqlQuery();userQuery.setDataSource(getDataSource());userQuery.setSql(sql);userQuery.setParameters(new SqlParameter(java.sql.Types.VARCHAR));userQuery.compile();return userQuery.execute(new Object[]{new String("cuiywA")});}

        List<User> list=userDao.QueryAllUser(); for(User u:list){System.out.println("name:"+u.getName()+" money: "+u.getMoney());}

package Cuiyw.Spring.Dao;import javax.sql.DataSource;import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.object.SqlUpdate;public class UserSqlUpdate extends SqlUpdate{public UserSqlUpdate(DataSource ds, String sql) {super(ds, sql);declareParameter(new SqlParameter(java.sql.Types.FLOAT) );declareParameter(new SqlParameter(java.sql.Types.VARCHAR) );}public int updateUserMoney(String name,float money){compile();return update(new Object[]{new Float(money),new String(name)});}
}

<bean id="userSqlUpdate" class="Cuiyw.Spring.Dao.UserSqlUpdate">
<constructor-arg type="java.lang.String" index="1">
<value>update tb_user set money=? where name=?</value>
</constructor-arg>
<constructor-arg ref="dataSource" index="0"></constructor-arg>
</bean>

        UserSqlUpdate userSqlUpdate=(UserSqlUpdate)factory.getBean("userSqlUpdate");userSqlUpdate.updateUserMoney("cuiywA",666); 

        BasicDataSource dataSource=(BasicDataSource)factory.getBean("dataSource");SqlFunction sf=new SqlFunction(dataSource,"select count(1) from tb_user;");sf.compile();int count=sf.run();System.out.println("User Count:"+count);

    public Boolean outInMoney(int toUserId,float money){String sql="update  tb_user set money=money+? where id=? ";int row=getJdbcTemplate().update(sql, new Object[]{money,toUserId});if(row>0){return true;}return false;}public Boolean transfer(int fromUserId, int toUserId, float transferMoney) {Boolean out= outInMoney(fromUserId,-transferMoney);Boolean in=outInMoney(toUserId,transferMoney);return out∈}

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/>
</bean>

 <!-- 配置业务层代理 -->
<bean id="userDaoProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"><!-- 配置目标对象 --><property name="target" ref="userDao"/><!-- 注入事务管理器 --><property name="transactionManager" ref="transactionManager"/><!-- 注入事务的属性 --><property name="transactionAttributes"><props><prop key="transfer">PROPAGATION_REQUIRED</prop></props></property>
</bean>

        List<User> list=userDao.QueryAllUser(); for(User u:list){System.out.println("name:"+u.getName()+" money: "+u.getMoney());}userDao.transfer(1, 2, 100);list=userDao.QueryAllUser(); for(User u:list){System.out.println("name:"+u.getName()+" money: "+u.getMoney());}

    public Boolean transfer(int fromUserId, int toUserId, float transferMoney) {Boolean out= outInMoney(fromUserId,-transferMoney);int a=1/0;Boolean in=outInMoney(toUserId,transferMoney);return out∈}

        IUserDAO userDao=(IUserDAO)factory.getBean("userDaoProxy");

          ApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"ApplicationContext.xml"});BeanFactory factory=context;IUserDAO userDao=(IUserDAO)factory.getBean("userDaoProxy");List<User> list=userDao.QueryAllUser(); for(User u:list){System.out.println("name:"+u.getName()+" money: "+u.getMoney());}try{userDao.transfer(1, 2, 100);}catch(Exception e){}list=userDao.QueryAllUser(); for(User u:list){System.out.println("name:"+u.getName()+" money: "+u.getMoney());}