oreratortable.java

spring 源码,用于spring框架学习者以及spring框架的爱好者学习

package jdbc;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.ArrayList;
import java.util.List;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;

public class OreratorTable {
	private JdbcTemplate jtl = null;
	public OreratorTable()
	{
		ApplicationContext ac = new ClassPathXmlApplicationContext("applicationjd.xml");
		jtl = (JdbcTemplate)ac.getBean("template");
	}
	//数据插入
	public void insert()
	{
		String sql = "insert into demojdbc(name,password) values ('0712','panspring')";
		jtl.update(sql);
	}
	public void insertTest(Person p)
	{
		String sql = "insert into demojdbc(name,password) values ('"+p.getName()+"','"+p.getPassword()+"')";
		jtl.update(sql);
	}
	public void insertAdd(Person p)
	{
		String sql = "insert into demojdbc(name,password) values (?,?)";
		Object[] para = new Object[]{p.getName(),p.getPassword()};
		int[] types = new int[]{Types.VARCHAR,Types.VARCHAR};
		jtl.update(sql, para, types);
	}
	//数据的修改
	public void updateTest(Person p)
	{
		String sql = "update demojdbc set " +
				"name='"+p.getName()+"',password='"+p.getPassword()+"' where id='"+p.getId()+"'";
		jtl.update(sql);
	}
	public void update(Person p)
	{
		String sql = "update demojdbc set name=?,password=? where id=?";
		Object ob[] = new Object[]{p.getName(),p.getPassword(),p.getId()};
		int types[] = new int[]{Types.VARCHAR,Types.VARCHAR,Types.INTEGER};
		jtl.update(sql,ob,types);
	}
	
	//数据查询(所有)
	public List QueryTest()
	{
		List list = null;
		String sql = "select * from demojdbc";
		list = jtl.queryForList(sql);
		return list;
	}
	public List Query()
	{
		final List list = new ArrayList();
		String sql = "select * from demojdbc";
		Object ob[] = new Object[]{};
		jtl.query(sql,ob,new RowCallbackHandler(){
			public void processRow(ResultSet rs) throws SQLException
			{
				Person p = new Person();
				p.setId(rs.getInt(1));
				p.setName(rs.getString(2));
				p.setPassword(rs.getString(3));
				list.add(p);
			}
		});
		return list;
	}
	//数据查询(根据ID条件查询)
	public List QueryId(int id)
	{
		List list = null;
		String sql = "select * from demojdbc where id='"+id+"'";
		list = jtl.queryForList(sql);
		return list;
	}
	public List QueryIdTest(int id)
	{
		final List list = new ArrayList();
		String sql = "select * from demojdbc where id='"+id+"'";
		Object ob[] = new Object[]{};
		jtl.query(sql, ob,new RowCallbackHandler(){
			public void processRow(ResultSet rs) throws SQLException
			{
				Person p = new Person();
				p.setId(rs.getInt(1));
				p.setName(rs.getString(2));
				p.setPassword(rs.getString(3));
				list.add(p);
			}
		});
		return list;
	}
	public List QueryIdTestAA(int id)
	{
		final List list = new ArrayList();
		String sql = "select * from demojdbc where id=?";
		Object ob[] = new Object[]{id};
		//int types[] = new int[]{Types.INTEGER};
		jtl.query(sql, ob,new RowCallbackHandler(){
			public void processRow(ResultSet rs) throws SQLException
			{
				Person p = new Person();
				p.setId(rs.getInt(1));
				p.setName(rs.getString(2));
				p.setPassword(rs.getString(3));
				list.add(p);
			}
		});
		return list;
	}
	//根据ID删除
	public void delete(int id)
	{
		String sql = "delete from demojdbc where id='"+id+"'";
		jtl.update(sql);
	}
	public void deleteTest(int id)
	{
		String sql = "delete from demojdbc where id=?";
		Object ob[] = new Object[]{id};
		//int types[] = new int[]{Types.INTEGER};
		jtl.update(sql,ob);
	}
}