使用SpringMVC轻松处理多种数据库 (springmvc处理数据库)
随着互联网的发展和数据量的不断增加，各种数据库也应运而生。其中常见的关系型数据库有MySQL、Oracle、SQL Server等，非关系型数据库有MongoDB、Redis等。在实际的项目开发中，我们往往需要同时连接和操作多个不同类型的数据库。SpringMVC提供了强大的数据访问层支持，能够轻松处理多种数据库，本文将介绍如何使用SpringMVC实现多种数据库的连接和操作。
1. 引入SpringMVC数据访问支持
在项目中引入SpringMVC数据访问支持，需要在pom.xml文件中添加对应依赖。以下是集成MySQL、Oracle、SQL Server和MongoDB的依赖：
“`
org.springframework
spring-jdbc
5.1.8.RELEASE
mysql
mysql-connector-java
8.0.13
com.oracle
ojdbc6
11.2.0.3
com.microsoft.sqlserver
mssql-jdbc
7.0.0.jre8
org.springframework.data
spring-data-mongodb
2.1.7.RELEASE
org.mongodb
mongodb-driver-sync
3.12.2
“`
其中，spring-jdbc是Spring JDBC的核心包，包含了Spring JDBC的所有功能。mysql-connector-java是MySQL的Java驱动。ojdbc6是Oracle的Java驱动。 mssql-jdbc是SQL Server的Java驱动。spring-data-mongodb是Spring封装的操作MongoDB的Java包。mongodb-driver-sync是MongoDB的Java驱动。
2. 配置数据源
在配置文件中添加数据源相关信息。以下是MySQL、Oracle、SQL Server和MongoDB的配置示例：
MySQL：
“`
spring.datasource.url=jdbc:mysql://localhost:3306/test
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
“`
Oracle：
“`
spring.datasource.url=jdbc:oracle:thin:@localhost:1521:XE
spring.datasource.username=system
spring.datasource.password=123456
spring.datasource.driverClassName=oracle.jdbc.driver.OracleDriver
“`
SQL Server：
“`
spring.datasource.url=jdbc:sqlserver://localhost:1433;databaseName=test
spring.datasource.username=sa
spring.datasource.password=123456
spring.datasource.driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver
“`
MongoDB：
“`
spring.data.mongodb.uri=mongodb://localhost:27017/test
“`
3. 编写Dao层代码
创建对应的Dao类，在其中提供操作数据库的方法，实现数据的增删改查等操作。以下是MySQL、Oracle、SQL Server和MongoDB的Dao类示例：
MySQL：
“`
@Repository
public class UserDao {
@Autowired
JdbcTemplate jdbcTemplate;
public List findAll() {
return jdbcTemplate.query(“select * from user”, new BeanPropertyRowMapper(User.class));
}
public void add(User user) {
jdbcTemplate.update(“insert into user (name, age) values (?, ?)”, user.getName(), user.getAge());
}
public void delete(long id) {
jdbcTemplate.update(“delete from user where id = ?”, id);
}
public void update(User user) {
jdbcTemplate.update(“update user set name = ?, age = ? where id = ?”, user.getName(), user.getAge(), user.getId());
}
}
“`
Oracle：
“`
@Repository
public class UserDao {
@Autowired
JdbcTemplate jdbcTemplate;
public List findAll() {
return jdbcTemplate.query(“select * from \”user\””, new BeanPropertyRowMapper(User.class));
}
public void add(User user) {
jdbcTemplate.update(“insert into \”user\” (name, age) values (?, ?)”, user.getName(), user.getAge());
}
public void delete(long id) {
jdbcTemplate.update(“delete from \”user\” where id = ?”, id);
}
public void update(User user) {
jdbcTemplate.update(“update \”user\” set name = ?, age = ? where id = ?”, user.getName(), user.getAge(), user.getId());
}
}
“`
SQL Server：
“`
@Repository
public class UserDao {
@Autowired
JdbcTemplate jdbcTemplate;
public List findAll() {
return jdbcTemplate.query(“select * from [user]”, new BeanPropertyRowMapper(User.class));
}
public void add(User user) {
jdbcTemplate.update(“insert into [user] (name, age) values (?, ?)”, user.getName(), user.getAge());
}
public void delete(long id) {
jdbcTemplate.update(“delete from [user] where id = ?”, id);
}
public void update(User user) {
jdbcTemplate.update(“update [user] set name = ?, age = ? where id = ?”, user.getName(), user.getAge(), user.getId());
}
}
“`
MongoDB：
“`
@Repository
public class UserDao {
@Autowired
private MongoTemplate mongoTemplate;
public List findAll() {
return mongoTemplate.findAll(User.class);
}
public void add(User user) {
mongoTemplate.save(user);
}
public void delete(User user) {
mongoTemplate.remove(user);
}
public void update(User user) {
mongoTemplate.save(user);
}
}
“`
其中，JdbcTemplate是Spring提供的JDBC模板，能够简化JDBC的操作。BeanPropertyRowMapper是Spring提供的一个实现了ResultSetExtractor接口的类，能够将一个ResultSet对象转换成一个Java对象。MongoTemplate是Spring封装的操作MongoDB的类。
4. 编写Service层代码
创建对应的Service类，在其中调用Dao层提供的方法，实现业务逻辑的处理。以下是MySQL、Oracle、SQL Server和MongoDB的Service类示例：
MySQL：
“`
@Service
public class UserService {
@Autowired
UserDao userDao;
public List findAll() {
return userDao.findAll();
}
public void add(User user) {
userDao.add(user);
}
public void delete(long id) {
userDao.delete(id);
}
public void update(User user) {
userDao.update(user);
}
}
“`
Oracle：
“`
@Service
public class UserService {
@Autowired
UserDao userDao;
public List findAll() {
return userDao.findAll();
}
public void add(User user) {
userDao.add(user);
}
public void delete(long id) {
userDao.delete(id);
}
public void update(User user) {
userDao.update(user);
}
}
“`
SQL Server：
“`
@Service
public class UserService {
@Autowired
UserDao userDao;
public List findAll() {
return userDao.findAll();
}
public void add(User user) {
userDao.add(user);
}
public void delete(long id) {
userDao.delete(id);
}
public void update(User user) {
userDao.update(user);
}
}
“`
MongoDB：
“`
@Service
public class UserService {
@Autowired
UserDao userDao;
public List findAll() {
return userDao.findAll();
}
public void add(User user) {
userDao.add(user);
}
public void delete(User user) {
userDao.delete(user);
}
public void update(User user) {
userDao.update(user);
}
}
“`
5. 编写Controller层代码
创建对应的Controller类，在其中调用Service层提供的方法，实现接口的处理。以下是MySQL、Oracle、SQL Server和MongoDB的Controller类示例：
MySQL：
“`
@RestController
public class UserController {
@Autowired
UserService userService;
@GetMapping(“/user”)
public List findAll() {
return userService.findAll();
}
@PostMapping(“/user”)
public void add(@RequestBody User user) {
userService.add(user);
}
@DeleteMapping(“/user/{id}”)
public void delete(@PathVariable(“id”) long id) {
userService.delete(id);
}
@PutMapping(“/user”)
public void update(@RequestBody User user) {
userService.update(user);
}
}
“`
Oracle：
“`
@RestController
public class UserController {
@Autowired
UserService userService;
@GetMapping(“/user”)
public List findAll() {
return userService.findAll();
}
@PostMapping(“/user”)
public void add(@RequestBody User user) {
userService.add(user);
}
@DeleteMapping(“/user/{id}”)
public void delete(@PathVariable(“id”) long id) {
userService.delete(id);
}
@PutMapping(“/user”)
public void update(@RequestBody User user) {
userService.update(user);
}
}
“`
SQL Server：
“`
@RestController
public class UserController {
@Autowired
UserService userService;
@GetMapping(“/user”)
public List findAll() {
return userService.findAll();
}
@PostMapping(“/user”)
public void add(@RequestBody User user) {
userService.add(user);
}
@DeleteMapping(“/user/{id}”)
public void delete(@PathVariable(“id”) long id) {
userService.delete(id);
}
@PutMapping(“/user”)
public void update(@RequestBody User user) {
userService.update(user);
}
}
“`
MongoDB：
“`
@RestController
public class UserController {
@Autowired
UserService userService;
@GetMapping(“/user”)
public List findAll() {
return userService.findAll();
}
@PostMapping(“/user”)
public void add(@RequestBody User user) {
userService.add(user);
}
@DeleteMapping(“/user”)
public void delete(@RequestBody User user) {
userService.delete(user);
}
@PutMapping(“/user”)
public void update(@RequestBody User user) {
userService.update(user);
}
}
“`
6. 测试接口
启动项目，在浏览器或Postman中访问接口，测试数据的增删改查功能。以下是MySQL、Oracle、SQL Server和MongoDB的测试接口：
MySQL：
“`
GET http://localhost:8080/user
POST http://localhost:8080/user Body: {“name”:”tom”,”age”:18}
PUT http://localhost:8080/user Body: {“id”:1,”name”:”tom”,”age”:19}
DELETE http://localhost:8080/user/1
“`
Oracle：
“`
GET http://localhost:8080/user
POST http://localhost:8080/user Body: {“name”:”tom”,”age”:18}
PUT http://localhost:8080/user Body: {“id”:1,”name”:”tom”,”age”:19}
DELETE http://localhost:8080/user/1
“`
SQL Server：
“`
GET http://localhost:8080/user
POST http://localhost:8080/user Body: {“name”:”tom”,”age”:18}
PUT http://localhost:8080/user Body: {“id”:1,”name”:”tom”,”age”:19}
DELETE http://localhost:8080/user/1
“`
MongoDB：
“`
GET http://localhost:8080/user
POST http://localhost:8080/user Body: {“name”:”tom”,”age”:18}
PUT http://localhost:8080/user Body: {“id”:”5e6cef61f6fb8a43b0e6b9a9″,”name”:”tom”,”age”:19}
DELETE http://localhost:8080/user Body: {“id”:”5e6cef61f6fb8a43b0e6b9a9″,”name”:”tom”,”age”:18}
“`
相关问题拓展阅读：
springmvc+mybatis怎么使用线程进行数据库操作
首先，你的确定数据的主键是否可以返配使用序列自增。
如果可以那么你可以在插入数察纯据的时候获取序列里的值，这样数据就不会重复了。
其次，可以创建一个公共方漏没指法，进行数据的插入操作，并且方法类型声明为 static synchronized
类型，这样基本上就不会出现数据重复的现象了
最后，要看你是怎么获得待插入源数据了，这个获得数据源的方法也做成static synchronized的公
共方法。
关于springmvc处理数据库的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。
