tsdaojdbc.java

自己做的关于spring框架的使用

package myspring.v3.ts;

import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

public class TsDaoJDBC extends JdbcDaoSupport implements TsDao{
	
	/* (non-Javadoc)
	 * @see myspring.v3.ts.TsDao#saveTs(int, java.lang.String)
	 */
	public void saveTs(final int id, final String name){
		DataSourceTransactionManager tm = new DataSourceTransactionManager(this.getDataSource());
		TransactionTemplate tt = new TransactionTemplate (tm);
				
		Object result = tt.execute(new TransactionCallback() {
		    public Object doInTransaction(TransactionStatus status) {
		        int count = 0;
		        String sql = "insert into spring_ts(id, name) values(" + id +",'" + name + "')";
		        count = getJdbcTemplate().update(sql);
		        count += getJdbcTemplate().update(sql);
		        //xxxDao.add();
		        //yyyDao.delete();
		        return new Integer(count);
		    }
		});
		System.out.println(result);
		//tm.commit(tm.status);
		
		
	}
	
	
	
	//不需要返回值
	/* (non-Javadoc)
	 * @see myspring.v3.ts.TsDao#saveTsWhithoutResult(int, java.lang.String)
	 */
	public void saveTsWhithoutResult(final int id, final  String name){
		DataSourceTransactionManager tm = new DataSourceTransactionManager(this.getDataSource());
		TransactionTemplate tt = new TransactionTemplate (tm);
		tt.execute(new TransactionCallbackWithoutResult() {
			protected void doInTransactionWithoutResult(TransactionStatus status) {
		        String sql = "insert into spring_ts(id, name) values(" + id +",'" + name + "')";
		        getJdbcTemplate().update(sql);
		        getJdbcTemplate().update(sql);
		    }
		});
	}

	
	//声明式事务处理,注意异常的处理（一定要抛出异常！）
	/* (non-Javadoc)
	 * @see myspring.v3.ts.TsDao#newSaveMethod(int, java.lang.String)
	 */
	public void newSaveMethod(int id, String name) throws DataAccessException{
		try{
			String sql = "insert into spring_ts(id, name) values(1,'name')";
			JdbcTemplate jt = getJdbcTemplate();
			jt.update(sql);
			jt.update(sql);
		} catch (DataAccessException e){
			e.printStackTrace();
			throw e;
		}
	}
	
	
}