创建项目
打开IDEA,选择创建一个新的项目,并勾选以下几项
项目命名为SBootMysqldemo,点击完成。
打开本地MySQL
请确定本地安装了MySQL,并且能够连接,我是用docker启动了一个MySQL容器,端口指向为3306
使用Navicat连接,并连接成功
不使用docker和Navicat也可以,只要安装了MySQL,并且能连接就行,然后创建一个我们要用的数据库命名为testMysql
如果下方提示没有下载driver,点击下载
最后填入mysql密码,测试连接
上面这个步骤不是非必要的。
别急着跑,因为跑起来你会发现出问题,因为我们需要去application.properties配置数据库连接信息。打开application.properties
添加
spring.datasource.driver-class-name = com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/testMysql?setUnicode=true&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=123456
一定要注意,不要在这些信息最后尾部留下什么空格之类的,否则你老半天找不到错在哪。这时候可以run起来了,看看有什么情况。http://localhost:8080,然后出现错误提示的页面Whitelabel Error Page,就对了。
开始操作数据库
新建一个包mysqlclass。在里面创建一个class叫UserController,再创建一个interface叫UserMapper。
UserController是向外提供接口映射的。UserMapper是操作数据库用的。打开UserController,添加接口。
@RestController
public class UserController {
@RequestMapping("/getuserlist")
public String getUserList()
{
return "获取成功!";
}
}
重启,http://localhost:8080/getuserlist访问,没问题,下一步。
创建一个User(class),添加属性,并实现setter和getter。
package com.cyhai.demo.mysqlclass.model;
public class User {
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getUserpassword() {
return userpassword;
}
public void setUserpassword(String userpassword) {
this.userpassword = userpassword;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public String username;
public String userpassword;
public int age;
public String sex;
}
打开UserMapper,添加一个查询注解,返回所有User类型的数据。
package com.cyhai.demo.mysqlclass;
import com.cyhai.demo.mysqlclass.model.User;
import org.apache.ibatis.annotations.Select;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public interface UserMapper {
@Select("select * from usertable order by user_id desc")
List<User> getUserList();
}
之后,打开Navicat,添加一个表,名为usertable,并添加User属性对应的字段,与自增长的user_id
往表里手动添加两列数据。
然后返回项目。我们创建一个Server(不要问我为什么不叫Service,我不想说,因为手抖了),让数据库的数据给到接口。创建一个interface名为UserServer。再创建一个serverimpl包,在里面创建一个class名为UserServerimpl。
打开UserServer并定义一个获取User列表的方法
@Service
public interface UserServer {
List<User> getUserList();
}
打开UserServerimpl,执行UserServer的方法。
@Repository
public class UserServerimpl implements UserServer {
@Autowired
private UserMapper userMapper;
@Override
public List<User> getUserList() {
try {
List<User> users = userMapper.getUserList();
return users;
}
catch (Exception e)
{
throw e;
// return null;
}
}
}
再打开UserController,把getUserList之前的代码修改为
@Autowired
private UserServerimpl userServer;
@RequestMapping("/getuserlist")
public List<User> getUserList()
{
return userServer.getUserList();
}
然后,重启项目,你会发现出错了别急着跑起来,这时候会出现@Autowired的注入问题
转移到项目入口
@MapperScan("com.cyhai.demo")
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
}
这次可以重启跑了。然后键入http://localhost:8080/getuserlist,返回结果
[ { "username": "蔡虚昆", "userpassword": "000000", "age": 21, "sex": "女" }, { "username": "狗剩", "userpassword": "123456", "age": 18, "sex": "男" } ]
查询操作OK了。接下来尝试插入数据。
打开UserMapper,新增一条插入数据语句。返回的是一个整型,因为如果插入数据OK的话,是可以返回插入数据的条数。当然你也可以不返回。
@Insert("insert into usertable(username,userpassword,age,sex) values(#{username},#{userpassword},#{age},#{sex})")
int AddUser(User user);
打开UserServer,添加一个插入数据的方法。
String AddUser(User user);
打开UserServerimpl,实现插入方法
@Override
public String AddUser(User user) {
try {
int i = userMapper.AddUser(user);
return "添加成功" + i + "条数据";
}
catch (Exception e)
{
throw e;
}
}
打开UserController,添加一个插入数据的post接口
@PostMapping("/adduser")
public String addUser(User user)
{
return userServer.AddUser(user);
}
重启,键入http://localhost:8080/adduser,输入参数(不要说参数?什么东西,就是一个User)。
查看数据库
到此,数据库操作已经做到了,后面会说,使用docker部署这个项目