springboot编程开发

SpringBoot + MySQL

2019-07-24  本文已影响0人  cyhai

创建项目

打开IDEA,选择创建一个新的项目,并勾选以下几项


image.png
image.png

项目命名为SBootMysqldemo,点击完成。

打开本地MySQL

请确定本地安装了MySQL,并且能够连接,我是用docker启动了一个MySQL容器,端口指向为3306


image.png

使用Navicat连接,并连接成功


image.png
不使用docker和Navicat也可以,只要安装了MySQL,并且能连接就行,然后创建一个我们要用的数据库命名为testMysql
image.png 打开项目,在右边找到Database, 屏幕快照 2019-07-24 下午1.51.27.png

如果下方提示没有下载driver,点击下载


image.png
最后填入mysql密码,测试连接
image.png
上面这个步骤不是非必要的。

别急着跑,因为跑起来你会发现出问题,因为我们需要去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。


image.png

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


image.png

往表里手动添加两列数据。


image.png

然后返回项目。我们创建一个Server(不要问我为什么不叫Service,我不想说,因为手抖了),让数据库的数据给到接口。创建一个interface名为UserServer。再创建一个serverimpl包,在里面创建一个class名为UserServerimpl。


image.png
打开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的注入问题


image.png

转移到项目入口


image.png
image.png
@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)。

image.png
image.png
查看数据库
image.png

到此,数据库操作已经做到了,后面会说,使用docker部署这个项目

上一篇 下一篇

猜你喜欢

热点阅读