前言:
目前朋友们对“vs连接mysql数据库增删改查代码”大概比较注重,小伙伴们都需要学习一些“vs连接mysql数据库增删改查代码”的相关文章。那么小编同时在网络上网罗了一些关于“vs连接mysql数据库增删改查代码””的相关资讯,希望朋友们能喜欢,你们一起来学习一下吧!摘要:本文是springboot工程使用JdbcTemplate连接Mysql数据库,实现增删改查的实例,及在搭建过程中碰到的几个问题,前几篇介绍怎么搭建SpringBoot工程,接下来直接入正题
什么是JDBC?
JDBC(Java DataBase Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。
JDBC的原理就是通过Connection这个类获取数据库的连接,然后通过PreparedStatement类处理SQL语句,再通过它的.setObject方法传入数据,最后通过方法.executeUpdate()和.executeQuery()执行更新
JdbcTemplate
template,是模板的意思,是Spring框架为我们提供的,JdbcTemplate是Spring框架自带的对JDBC操作的封装,目的是提供统一的模板方法使对数据库的操作更加方便、友好,效率也不错。但是功能还是不够强大(比如不支持级联属性),在实际应用中还需要和hibernate、mybaties等框架混合使用。
JdbcTemplate类主要提供以下四类方法execute方法:用于执行任何SQL语句,一般用于执行DDL语句;update方法及batchUpdate方法:update方法用于执行新增、修改、删除等语句,batchUpdate方法用于执行批处理相关语句;query方法及queryForXXX方法:用于执行查询相关语句;call方法:用于执行存储过程、函数相关语句具体实现需要的jar包依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency>mysql的驱动jar包
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency>application.properties配置文件
spring.application.name=testserver.port=8088spring.datasource.url=jdbc:mysql://127.0.0.1:3306/db1spring.datasource.username=rootspring.datasource.password=root#说明一下,注释掉容易犯错的地方(后边会说明这个错误)#spring.datasource.driver-class-name=com.mysql.jdbc.Driverspring.datasource.driver-class-name=com.mysql.cj.jdbc.Driversql语句
/*Navicat MySQL Data TransferSource Server : localhost_3306Source Server Version : 50520Source Host : localhost:3306Source Database : db1Target Server Type : MYSQLTarget Server Version : 50520File Encoding : 65001Date: 2019-03-04 22:36:54*/SET FOREIGN_KEY_CHECKS=0;-- ------------------------------ Table structure for `user`-- ----------------------------DROP TABLE IF EXISTS `user`;CREATE TABLE `user` ( `id` varchar(32) NOT NULL, `name` varchar(20) DEFAULT NULL, `sex` varchar(20) DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Records of user-- ----------------------------INSERT INTO `user` VALUES ('06170ace6fa94ac5aec51a4b30572fd0', 'Spring', 'Frame');INSERT INTO `user` VALUES ('1', '刘能', '男的');INSERT INTO `user` VALUES ('2', '王五', 'woman');INSERT INTO `user` VALUES ('3d0bd85cd40f4a8584d352accfaf6db6', 'Spring', 'Frame');INSERT INTO `user` VALUES ('a7ff791e54f648d9bc24dd4c472c1f84', 'Spring', 'Frame');Dao数据接口
package com.mundo.Test.service;import java.util.List;import com.mundo.Test.pojo.User;import com.mundo.Test.pojo.UserRowMapper;public interface UserService { List<User> queryAll(String sql, UserRowMapper userRowMapper, Object... objects); User selectById(String sql, UserRowMapper userRowMapper, String id); int updateById(String sql, Object... objects); int insert(String sql, Object... objects); int deleteById(String sql, String id);}接口实现
/** * */package com.mundo.Test.service.impl;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.stereotype.Service;import com.mundo.Test.pojo.User;import com.mundo.Test.pojo.UserRowMapper;import com.mundo.Test.service.UserService;/** * @ClassName: UserServiceImpl * @Description: TODO * @author Meng.Xu * @date 2019年3月4日 下午5:32:43 */@Servicepublic class UserServiceImpl implements UserService { @Autowired private JdbcTemplate jdbcTemplate; @Override public List<User> queryAll(String sql, UserRowMapper userRowMapper, Object... objects) { return jdbcTemplate.query(sql, userRowMapper, objects); } @Override public User selectById(String sql, UserRowMapper userRowMapper, String id) { return jdbcTemplate.queryForObject(sql, userRowMapper, id); } @Override public int updateById(String sql, Object...objects) { return jdbcTemplate.update(sql, objects); } @Override public int insert(String sql, Object... objects) { return jdbcTemplate.update(sql, objects); } @Override public int deleteById(String sql, String id) { return jdbcTemplate.update(sql, id); }}用的Junit 单元测试需要在pom.xml中加入
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency>单元测试增删改查
package com.mundo.Test;import java.util.List;import javax.annotation.Resource;import org.junit.Test;import org.junit.runner.RunWith;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.test.context.junit4.SpringRunner;import com.alibaba.fastjson.JSONObject;import com.mundo.Test.pojo.User;import com.mundo.Test.pojo.UserRowMapper;import com.mundo.Test.service.UserService;import com.mundo.Test.util.UUIDUtil;@RunWith(SpringRunner.class)@SpringBootTestpublic class TestApplicationTests { @Resource private JdbcTemplate jdbcTemplate; private Logger logger = LoggerFactory.getLogger(TestApplicationTests.class); @Resource private UserService userService; @Test public void contextLoads() { String sql = "select * from user"; List<User> queryAll = userService.queryAll(sql, new UserRowMapper()); System.out.println("返回对象集合:" + JSONObject.toJSONString(queryAll)); System.out.println("\n"); sql = "select * from user where id = ?"; User user = userService.selectById(sql, new UserRowMapper(), "1"); System.out.println("返回对象:" + JSONObject.toJSONString(user)); System.out.println("\n"); sql = "update user set name = ?, sex = ? where id = ?"; int updateById = userService.updateById(sql, "王五", "woman", "2"); System.out.println("更新成功"); System.out.println("\n"); sql = "insert into user(id,name,sex)values(?,?,?)"; int insert = userService.insert(sql, UUIDUtil.getUUID(), "Spring", "Frame"); System.out.println("插入成功"); System.out.println("\n"); sql = "delete from user where id = ?"; int deleteById = userService.deleteById(sql, "3"); System.out.println("删除成功"); }}实体类
package com.mundo.Test.pojo;/** * @ClassName: User * @Description: TODO * @author Meng.Xu * @date 2019年3月4日 下午9:09:22 */public class User { private String id; private String name; private String sex; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; }}数据封装类(返回自定义类型根据需要),这个是比较简单易懂,感兴趣的可以自己利用泛型,反射写一个通用的(项目中实体类肯定很多)
package com.mundo.Test.pojo;import java.sql.ResultSet;import java.sql.SQLException;import org.springframework.jdbc.core.RowMapper;/** * @ClassName: UserRowMapper * @Description: TODO * @author Meng.Xu * @date 2019年3月4日 下午10:02:29 */public class UserRowMapper implements RowMapper<User> { User user = null; @Override public User mapRow(ResultSet rs, int rowNum) throws SQLException { System.out.println(rowNum); // 先从结果集里把数据得到 // 然后把数据封装到对象里 user = new User(); user.setId(rs.getString("id")); user.setName(rs.getString("name")); user.setSex(rs.getString("sex")); return user; }}
Jdbctemplate到这里简单的增删改查就告一段落了,接下来将介绍SpringBoot+Mybatis连接数据库,敬请期待!
每天进步一点点,前进不止一小点,你侬我侬不如码农,欢迎关注转发评论!
标签: #vs连接mysql数据库增删改查代码