数据库|Spring整合JDBC
欢迎点击「算法与编程之美」↑关注我们！
本文首发于微信公众号："算法与编程之美"，欢迎关注，及时了解更多此系列文章。
欢迎加入团队圈子！与作者面对面交流！直接点击！
什么是 JDBC
JDBC代表Java Database Connectivity，它是提供一组JavaApi来访问关系数据库的Java程序。这些Apis可以使Java应用程序执行sql语句，能够与任何符合sql规范的数据库进行交互。
JDBC提供了一个灵活的框架来编写操作数据库的独立的应用程序，该程序能够运行在不同的平台上且不需修改，能够与不同的DBMS 进行交互。
Spring整合JDBC
一 导入需要的包
这里需要的包有如下：
<!--spring引入start-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<!--spring AOP所要用到的包start-->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.9</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<!--spring AOP所要用到的包end-->
<!--spring jdbc所要用到的包start-->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.4</version>
</dependency>
<!--spring jdbc所要用到的包end-->
<!--数据库连接的包-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.38</version>
</dependency>
二 选择数据源
在beans.xml中创建dataSource数据源
<!-- 1.配置数据源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<!-- 数据库驱动 -->
<propertyname="driverClassName" value="{jdbc.driverClassName}"/>
<!-- 连接数据库的url -->
<property name="url" value="{jdbc.url}"/>
<!-- 连接数据库的用户名 -->
<property name="username" value="{jdbc.username}"/>
<!-- 连接数据库的密码 -->
<property name="password" value="{jdbc.password}"/>
</bean>
创建数据源配置信息，创建一个jdbc.propertices文件来设置数据库的连接信息
validationQuery=SELECT 1 FROM DUAL
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=UTC
jdbc.username=root
jdbc.password=123456
配置JDBC模板
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!-- 默认必须使用数据源 -->
<property name="dataSource" ref="dataSource"/>
</bean>
定义id为accountDao的Bean
<bean id="accountDao" class="com.yujl.jdbc.dao.UserDaoImpl">
<!-- 将jdbcTemplate注入到accountDao实例中 -->
<property name="jdbcTemplate" ref="jdbcTemplate"/>
</bean>
三 DAO的实现
首先编写接口类，包括四个方法：增删改查
public interface UserDao {
public void add(User user);
public void delete(int id);
public User review(int id);
public void update(User user , int id);
}
接着实现这个接口并编写具体逻辑代码
public class UserDaoImpl implements UserDao {
// 声明一个JdbcTmplate属性及其Setter方法
private JdbcTemplate jdbcTemplate;
//通过配置文件beans.xml
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
//对数据库进行添加操作
@Override
public void add(User user) {
String sql = "insert into user(name, password, age) values(?,?,?)";
jdbcTemplate.update(sql,user.getName(),user.getPassword(),user.getAge());
}
// 删除操作
@Override
public void delete(int id) {
String sql = "delete from user where id = ?";
jdbcTemplate.update(sql,id);
}
//根据ID查找信息
@Override
public User review(int id) {
String sql = "select * from user u where id = ?";
RowMapper<User> rowMapper = new BeanPropertyRowMapper<User>(User.class);
return jdbcTemplate.queryForObject(sql,rowMapper,id);
}
//根据ID对User进行更新
@Override
public void update(User user, int id) {
String sql = "updete user set name = ?,password = ?, age = ? where id = ?";
jdbcTemplate.update(sql,user.getName(),user.getPassword(),user.getAge(),id);
}
//创建一个内部类通过实现RowMapper来返回java对象
public class UserRowMapper implements RowMapper<User>{
@Override
public User mapRow(ResultSet resultSet, int i) throws SQLException {
User u = new User();
u.setName(resultSet.getString(2));
u.setPassword(resultSet.getString(3));
u.setAge(resultSet.getInt(4));
return u;
}
}
}
四 User类
根据数据库创建相应的类，这里数据库是User，所以创建User类，具体代码如下
public class User {
private int id; //id
private String name; //名字
private String password; //密码
private int age; //年龄
public User(){};
public User(String name, String password, int age){
this.name = name;
this.password = password;
this.age = age;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
return "User{" +
"id=" + id +
", name='" + name + '/'' +
", password='" + password + '/'' +
", age=" + age +
'}';
}
}
五 测试
到这里代码都差不多写完了，接下来测试一下
public class jdbcTest {
public static void main(String[] args) {
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("/beans.xml"); //加载配置文件
UserDao userDao = (UserDao) applicationContext.getBean("accountDao");
//查询ID为4的用户信息
System.out.println(userDao.review(4));
//新增一条纪录
userDao.add(new User("liuyujiang","132456",15));
}
}
运行结果如下：
总结
Spring的JDBC模块负责数据库资源管理和错误处理，大大简化了开发人员对数据库的操作，使得开发人员可以从繁琐的数据库操作中解脱出来。
END
编 辑 | 王文星
责 编 | 刘玉江
where2go 团队
微信号：算法与编程之美
长按识别二维码关注我们!
温馨提示： 点击页面右下角 “写留言”发表评论，期待您的参与！期待您的转发！
正文到此结束
- 本文标签： java db map CTO 总结 ACE id spring tab sql 代码 开发 Word AOP mysql classpath apr API 二维码 删除 IO 测试 cat 管理 value http mapper UTC ssl 数据库 IDE XML core bean tag root tar 数据 实例 src Property junit web https UI Select dataSource 微信公众号 ResultSet update 配置 App DBCP 文章 JDBC
- 版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
- 本文海报： 生成海报一 生成海报二
热门推荐
相关文章
近期评论
-
666
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
