Spring中的Jdbc

项目结构图：



(1)创建java project

(2)创建数据库(mysql)

create database mydb;

create table t_user(user_id int primary key auto_increment,username varchar(20),password varchar(20));

insert into t_user(username,password) values('java','1234');

insert into t_user(username,password) values('php','1234');

(3)添加spring类库

commons-logging.jar

log4j-1.2.15.jar

spring.jar

aspectjrt.jar(可选)

aspectjweaver.jar(可选)

(4)在src下添加spring配置文件

applicationContext.xml

log4j.properties

建议：

在搭建框架使用debug模式，

开发程序使用info模式

(5)实体类

com.tarena.entity.User

(6)连接数据库

添加mysql驱动库：

mysql-connector-java-5.1.16.jar

在spring配置文件中配置：

<!-- 连接数据库 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://127.0.0.1:3306/lirui"/>
<property name="username" value="root"/>
<property name="password" value="865631572"/>
</bean>

(7)编写DAO

(a)IUserDao接口类

public interface IUserDao {
int saveUser(User user);
int deleteUserById(User user);
int updateUserById(User user);

List<Map<String,Object>> findAllUser();
int countUser();
User findUserById(User user);
List<User> findAll();
}

(b)UserDaoImpl实现类

public class UserDaoImpl extends JdbcDaoSupport implements IUserDao {

@Override
public int saveUser(User user) {
String sql = "insert into t_user(username,password) values(?,?)";
return this.getJdbcTemplate().
update(sql, new Object[]{
user.getUsername(),user.getPassword()
});
}

@Override
public int deleteUserById(User user) {
String sql = "delete from t_user where user_id=?";
return this.getJdbcTemplate().update(sql, new Object[]{user.getUserId()});
}

@Override
public int updateUserById(User user) {
String sql = "update t_user set username=? where user_id=?";
return this.getJdbcTemplate().update(sql, new Object[]{user.getUsername(),user.getUserId()});
}

@Override
public int countUser() {
String sql = "select count(*) from t_user";
return this.getJdbcTemplate().queryForInt(sql);
}

@SuppressWarnings("unchecked")
@Override
public List<User> findAll() {
String sql = "select * from t_user";

return this.getJdbcTemplate().query(sql, new RowMapper(){

@Override
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
user.setUserId(rs.getInt("user_id"));
user.setUsername(rs.getString("username"));
user.setPassword(rs.getString("password"));
return user;
}});
}

@SuppressWarnings("unchecked")
@Override
public List<Map<String, Object>> findAllUser() {
String sql = "select * from t_user";
return this.getJdbcTemplate().queryForList(sql);
}

@Override
public User findUserById(User user) {
String sql = "select * from t_user where user_id = ?";
return (User)this.getJdbcTemplate().queryForObject(sql,new Object[]{user.getUserId()}, new RowMapper(){

@Override
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
user.setUserId(rs.getInt("user_id"));
user.setUsername(rs.getString("username"));
user.setPassword(rs.getString("password"));
return user;
}});
}

}

(c)在spring配置文件中配置UserDaoImpl

<!-- dao -->
<bean id="userDaoImpl" class="com.tarena.dao.impl.UserDaoImpl">
<property name="dataSource" ref="dataSource"/>
</bean>

其中name="dataSource"中不可改,因为UserDaoImpl继承JdbcDaoSupport类,这个类中有一个setDataSource(DataSource datasource)方法,采用的是Spring set方式

(8)测试

静态导包：

(1)jdk5.0以上

(2)方法必须是static修改方法

使用:

(1)import static 包名.静态方法名 例:import static org.junit.Assert.assertEquals;

(2)静态方法名(...)

//断言：预计值与实际值比较

assertEquals(预计值,实际值);

UserDaoImplTest测试类:

public class UserDaoImplTest {
private IUserDao iuserDao = null;
@Before
public void setUp(){
ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
iuserDao=(IUserDao)ac.getBean("userDaoImpl");
}

@Test
@Ignore
public void testSaveUser(){
//IUserDao iuserDao = new UserDaoImpl();
User user = new User();
user.setUsername("净净");
user.setPassword("1234");
int row= iuserDao.saveUser(user);
//断言：预计值,实际值比较
//assertEquals(预计值,实际值);
assertEquals(1,row);
}

@Test
@Ignore
public void testDeleteUserById(){
User user = new User();
user.setUserId(3);
int row = iuserDao.deleteUserById(user);
assertEquals(1, row);
}
@Test
@Ignore
public void testUpdateUserById(){
User user = new User();
user.setUserId(5);
user.setUsername("八戒");
int row = iuserDao.updateUserById(user);
assertEquals(1, row);
}

@Test
@Ignore
public void testFindAllUser(){
List<Map<String,Object>> list=iuserDao.findAllUser();
/*for (Map<String, Object> map : list) {
System.out.println(map.get("user_id")+" "+
map.get("username")

);
}*/
assertEquals(5, list.size());
}
@Test
@Ignore
public void testCountUser(){
System.out.println(iuserDao.countUser());
}

@Test
@Ignore
public void testFindUserById(){
User user = new User();
user.setUserId(1);
User u = iuserDao.findUserById(user);
System.out.println(u.getUsername());
}
@Test
public void testFindAll(){
List<User> users = iuserDao.findAll();
for (User user : users) {
System.out.println(user.getUserId()+" "+
user.getUsername()+" "+
user.getPassword()
);

}
}