用JdbcTemplate写的DAO的详细介绍

用JdbcTemplate写的DAO的详细介绍

1。**************************************首先看DAO类怎么具体实现***********************************************



package com.yinbodotcc;
/*
* 说明，在下面的例子中，凡是用？的均是我喜欢的，至少以后不用平凡用单引号了，呵呵；
*
* 下面这两种格式是通用的，
* jdbcTemplate.update(sql, new Object[]{new Integer(year)});
* jdbcTemplate.queryForXX(sql,new Object[]{name})
*
*/
import java.util.*;
import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;
import java.sql.*;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.PreparedStatementSetter;
import org.springframework.jdbc.core.BatchPreparedStatementSetter;

public class BookDao2 implements IBookDao
{
private JdbcTemplate jdbcTemplate;

//设置DataSource，并生成JdbcTemplate实例
public void setDs(DataSource ds)
{
jdbcTemplate=new JdbcTemplate(ds);
}

//以书名为依据来找寻某本/些书
public List<Book> select(String name)
{
List<Book> books=new ArrayList<Book>();

//下面这个也可以，但是我还是觉得用？的方式比较好
//String sql="select * from book where name='"+name+"'";
//Iterator it=jdbcTemplate.queryForList(sql).iterator();


String sql="select * from book where name=?";
Iterator it=jdbcTemplate.queryForList(sql,new Object[]{name}).iterator();

while(it.hasNext())
{
Map m=(Map)it.next();
String theName=m.get("name").toString();
int theBirthday=new Integer(m.get("pbYear").toString());
Book tempBook=new Book();
tempBook.setName(theName);
tempBook.setPbYear(theBirthday);
books.add(tempBook);

}
return books;

}

//插入某本书
public void insertBook(Book book)
{
//String sql="insert into book(name,pbYear) values('"+book.getName()+"',"+book.getPbYear()+")";
//jdbcTemplate.execute(sql);
//或者用update();

String sql="insert into book(name,pbYear) values(?,?)";
jdbcTemplate.update(sql, new Object[]{book.getName(),book.getPbYear()});

}

//插入很多书
public void insertBooks(List<Book> book)
{
final List<Book> tempBook=book;
String sql="insert into book(name,pbYear) values(?,?)";
jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter()
{
public void setValues(PreparedStatement ps,int i)throws SQLException
{
String name=tempBook.get(i).getName();
int pbYear=tempBook.get(i).getPbYear();
ps.setString(1, name);
ps.setInt(2, pbYear);
}
public int getBatchSize()
{
return tempBook.size();
}
});

}

//更新书的出版年月
public void updateBookPbYear(Book book,int year)
{
//内部类要访问得外围类得变量，必须是final
final String name=book.getName();
final String sql="update book set pbYear=? where name='"+name+"'";
final int temYear=year;

jdbcTemplate.update(new PreparedStatementCreator()
{
public PreparedStatement createPreparedStatement(Connection con)throws SQLException
{
PreparedStatement ps=con.prepareStatement(sql);
ps.setInt(1,temYear);
return ps;
}
});

jdbcTemplate.update(sql, new PreparedStatementSetter()
{
public void setValues(PreparedStatement ps)throws SQLException
{
ps.setInt(1,temYear);
}
});



//虽然需要得是int，但是我们这里给了它Integer是可以得
//jdbcTemplate.update(sql, new Object[]{new Integer(year)});

//当然直接updae里面放sql语句也是可以的。

}

//从库中删除某书
public void delete(Book book)
{
String sql="delete from book where name=?";
jdbcTemplate.update(sql, new Object[]{book.getName()});
}

//查询库中所有的书
public List<Book> selectAll()
{
List<Book> books=new ArrayList<Book>();


String sql="select * from book";
Iterator it=jdbcTemplate.queryForList(sql).iterator();

while(it.hasNext())
{
Map m=(Map)it.next();
String theName=m.get("name").toString();
int theBirthday=new Integer(m.get("pbYear").toString());
Book tempBook=new Book();
tempBook.setName(theName);
tempBook.setPbYear(theBirthday);
books.add(tempBook);

}
return books;
}
}

2。***************************************看看接口DAO的具体方法****************************************

package com.yinbodotcc;
import java.util.*;

public interface IBookDao {
public List<Book> select(String name);
public void insertBook(Book book);
public void updateBookPbYear(Book book,int year);
public void insertBooks(List<Book> book);
public void delete(Book book);
public List<Book> selectAll();

}

3。**************************************看看具体配置文件*************************************************

<?xml version="1.0" encoding="GBK"?>
<!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="datasource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName">
<value>com.mysql.jdbc.Driver</value>
</property>

<property name="url">
<value>jdbc:mysql://localhost:3306/yay</value>
</property>

<property name="username">
<value>root</value>
</property>

<property name="password">
<value>qwe123</value>
</property>
</bean>

<bean id="bookDao" class="com.yinbodotcc.BookDao">
<property name="ds">
<ref bean="datasource"/>
</property>
</bean>
<bean id="bookDao2" class="com.yinbodotcc.BookDao2">
<property name="ds">
<ref bean="datasource"/>
</property>
</bean>
</beans>