tasksjdbcdao.java

spring 数据连接范例 (jdbc)

package com.spring.jdbc;

import java.util.Iterator;
import java.util.List;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.RowMapperResultReader;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.mysql.jdbc.CallableStatement;

public class TasksJdbcDAO extends JdbcDaoSupport implements TasksDAO {

	public List getTasksNames() {
		JdbcTemplate jt = getJdbcTemplate();
		return jt.query("select taskname from tasks",
				new RowMapperResultReader(new TasksRowMapper()));
	}

	public List getTasktimeByName(String taskName) {
		JdbcTemplate jt = getJdbcTemplate();
		return jt.query("select tasktime from tasks where taskname='"
				+ taskName + "'", new RowMapperResultReader(
				new TasksRowMapper()));

	}

	public boolean insertRecord(String taskname, String tasktime) {
		JdbcTemplate jt = getJdbcTemplate();
		if (taskname == "" || tasktime == "")
			return false;
		else
			jt.execute("insert into tasks(taskname,tasktime) values('"+taskname+"','"+tasktime+"')");
		return true;
	}

	class TasksRowMapper implements RowMapper {
		public Object mapRow(ResultSet rs, int index) throws SQLException {
			return rs.getString(1);
		}
	}

	public static void main(String[] args) throws Exception {
		ApplicationContext ctx = new ClassPathXmlApplicationContext(
				"SpringConfig.xml");
		DataSource ds = (DataSource) ctx.getBean("dataSourceDBDirect");
		TasksJdbcDAO taskDao = new TasksJdbcDAO();

		taskDao.setDataSource(ds);
		Iterator tskIter = taskDao.getTasksNames().iterator();
		System.out.println("Result:");
		String temp = "";
		while (tskIter.hasNext()) {
			temp = tskIter.next().toString();
			System.out.println(temp);
			Iterator ttIter = taskDao.getTasktimeByName(temp).iterator();
			while (ttIter.hasNext()) {
				System.out.println(ttIter.next().toString());
			}
		}
		if(taskDao.insertRecord("this is no task","13:00"))
			System.out.println("insert success!");
	}
}