test.java

Spring2.0宝典

package lee;

import java.util.List;
import java.util.Iterator;

import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

import java.util.Map;
import java.sql.*;
import org.springframework.jdbc.object.MappingSqlQuery;
import org.springframework.jdbc.core.SqlParameter;

/**
 * @author  yeeku.H.lee [e-mail]
 * @version  1.0
 * Copyright (C), 2005-2008, yeeku.H.Lee
 * This program is protected by copyright laws.
 * Program Name:
 * Date: 
 */

public class Test
{
	
	public static void main(String[] args)throws Exception
	{

		ComboPooledDataSource ds = new ComboPooledDataSource();
		ds.setDriverClass("com.mysql.jdbc.Driver");
		ds.setJdbcUrl("jdbc:mysql://localhost:3306/j2ee");
		ds.setUser("root");
		ds.setPassword("32147");
        ds.setMaxPoolSize(40);
        ds.setMinPoolSize(2); 
        ds.setMaxStatements(180); 
		PersonMappingQuery pmq = new PersonMappingQuery(ds);
		Object[] values = {new Integer(30)};
		List personList = pmq.execute(values);
		for (Iterator it = personList.iterator() ; it.hasNext() ; )
		{
			System.out.println(it.next());
		}		
	}

}
class PersonMappingQuery extends MappingSqlQuery
{
	public PersonMappingQuery(DataSource ds)
	{
		super(ds, "SELECT * FROM person_test WHERE p_age > ?" );
		super.declareParameter(new SqlParameter("id", Types.INTEGER));
		compile();
	}
	public Object mapRow(ResultSet rs, int rowNumber) throws SQLException
	{
		Person p = new Person();
		p.setAge(rs.getInt(3));
		p.setName(rs.getString(2));
		return p;
	} 
}