使用DRUID，是阿里巴巴开源平台上一个数据库连接池实现，它结合了C3P0、DBCP等DB池的优点，同时加入了监控。
整合步骤
第一步：创建web项目，导入依赖
第二步：开发表对应的实体类
public class User {
private Integer id;
private String name;
private Integer age;
public User() {
}
public void setId(Integer id) {
this.id = id;
}
public void setName(String name) {
this.name = name;
}
public void setAge(Integer age) {
this.age = age;
}
public Integer getId() {
return id;
}
public String getName() {
return name;
}
public Integer getAge() {
return age;
}
@Override
public String toString() {
return "User{" +
"id=" + id +
", name='" + name + '\'' +
", age=" + age +
'}';
}
}
第三步：开发DAO接口和实现类
@Repository("UserDaoImpl")
public class UserDaoImpl extends JdbcDaoSupport implements UserDao {
@Override
public void addUser(User user) {
String sql="INSERT INTO testinstall (name,age) VALUES (?,?)";
getJdbcTemplate().update(sql,user.getName(),user.getAge());
}
@Override
public void deleteUser(User user) {
String sql="DELETE FROM testinstall WHERE id =?";
getJdbcTemplate().update(sql,user.getId());
}
@Override
public void updateUser(User user) {
String sql="UPDATE testinstall SET name = ? ,age=? WHERE id =?";
getJdbcTemplate().update(sql,user.getName(),user.getAge(),user.getId());
}
@Override
public User queryUser(final User user) {
String sql="SELECT * FROM testinstall WHERE id=? ";
User user1 = getJdbcTemplate().queryForObject(sql, new RowMapper<User>() {
@Override
public User mapRow(ResultSet rs, int rowNum) throws SQLException {
User user1 = new User();
String name = rs.getString("name");
int age = rs.getInt("age");
user1.setId(user.getId());
user1.setName(name);
user1.setAge(age);
return user1;
}
}, user.getId());
return user1;
}
@Override
public List<User> queryAll() {
String sql="SELECT * FROM testinstall ";
List<User> query = getJdbcTemplate().query(sql, new RowMapper<User>() {
@Override
public User mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
user.setId(id);
user.setName(name);
user.setAge(age);
return user;
}
});
return query;
}
}
开发DAO实现类：
继承JdbcDaoSupport
getJdbcTemplate()得到JdbcTemplate（需要注入）
第四步：配置整合
需要把模板类对象赋值给持久层的DAO
<context:component-scan base-package="com.zyh.*"></context:component-scan>
<context:property-placeholder location="classpath:db.properties"></context:property-placeholder>
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
<property name="driverClassName" value="${myDriverClass}" ></property>
<property name="url" value="${myUrl}"></property>
<property name="username" value="${myUsername}"></property>
<property name="password" value="${myPassword}"></property>
<property name="maxWait" value="3000"></property>
<property name="maxActive" value="100"></property>
<!--Druid监控-->
<property name="filters" value="wall,stat"/>
</bean>
<!--创建 JDBCTemplate对象 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
<bean id="UserDaoImpl" class="com.zyh.dao.impl.UserDaoImpl">
<property name="jdbcTemplate" ref="jdbcTemplate"></property>
</bean>
测试方法如下所示：
public class TestUserService {
@Qualifier("UserServiceImpl")
@Autowired
private UserServiceImpl userService;
@Test
public void testUserServiceImplQueryAll(){
List<User> users = userService.queryAll();
for (User user : users) {
Log.info(user);
}
}
}
观察输出如下所示：
修改配置文件如下所示：
<bean id="UserDaoImpl" class="com.zyh.dao.impl.UserDaoImpl">
<property name="dataSource" ref="dataSource"></property>
</bean>
我们修改了数据库的配置文件 直接抽取出来了db.properties 文件
这个是 DruidDatasource的源码 ：
第一个配置文件就是依赖下面的源码进行配置的
第二个配置文件就是依赖下面的源码进行配置的
注意点： 注意此属性 设置最大等待时间 3000毫秒
<property name="maxWait" value="3000"></property>
如果获取失败，可以快速抛异常，避免占用。
开发环境建议设置maxWait=3000(开发环境原因链接本来就慢)
我们在线上配置的时候 ，此属性可以设置的低一些 比如 300毫秒， 可以对于高并发起到一定的作用。
