时人莫小池中水，浅处无妨有卧龙。------唐·窦庠《醉中赠符载》

之前写过一个springboot的小项目

现在又在往里加东西啦！

之前没有对数据库添加支持，今天就往里整合SQLite吧！

首先先引入依赖

|------------------------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 | hljs xml <!-- https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter --> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.3</version> </dependency> <!-- sqlite驱动 --> <!-- https://mvnrepository.com/artifact/org.xerial/sqlite-jdbc --> <dependency> <groupId>org.xerial</groupId> <artifactId>sqlite-jdbc</artifactId> <version>3.32.3.2</version> </dependency> |

然后添加配置文件

|-----------------|-------------------------------------------------------------------------------------------------------| | 1 2 3 4 | hljs plaintext spring: datasource: url: jdbc:sqlite:data.db driver-class-name: org.sqlite.JDBC |

这个url配置可以参照我之前这篇SQLite入门のjava创建库表

当时创建的data.db文件在哪，这里就写哪

然后就开始写吧

创建Dao接口

|------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | hljs java package com.ruben.dao; import com.ruben.pojo.User; import org.apache.ibatis.annotations.*; import java.util.List; /** * @ClassName: UserDao * @Date: 2020/10/11 0011 13:24 * @Description: */ @Mapper public interface UserDao { @SelectProvider(type = UserMapper.class, method = "findUserByCondition") User findUserByCondition(User user); @InsertProvider(type = UserMapper.class, method = "insertUser") int insertUser(User user); } |

然后是Mapper

|------------------------------------------------------------------------------------------------------------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 | hljs java package com.ruben.dao; import com.aliyuncs.utils.StringUtils; import com.ruben.pojo.User; import com.ruben.utils.StringUtil; import org.apache.ibatis.jdbc.SQL; import org.thymeleaf.expression.Lists; import java.util.ArrayList; import java.util.List; /** * @ClassName: UserMapper * @Date: 2020/10/11 0011 13:26 * @Description: */ public class UserMapper { public String findUserByCondition(User user) { SQL sql = new SQL(); sql.SELECT("id,username,password"); sql.FROM("user"); if (user.getId() != null) { sql.WHERE("id=#{id}"); } else if (StringUtils.isNotEmpty(user.getUsername())) { sql.WHERE("username=#{username}"); } return sql.toString(); } public String insertUser(User user) { SQL sql = new SQL(); sql.INSERT_INTO("user"); sql.VALUES("id,username,password", "#{id},#{username},#{password}"); return sql.toString(); } } |

SQLite入门就是这么简单...

然后把原来的假数据替换成真数据

|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 | hljs java @Override public User getUserByUsername(String username) { User condition = new User(); condition.setUsername(username); //从缓存中获取，获取不到再从数据库中获取 String userJson = (String) stringRedisTemplate .opsForHash() .get(UserConstant.USER_CACHE, UserConstant.LOGIN_USER_PRE + username); if (StringUtils.isEmpty(userJson)) { //从数据库中获取 return userDao.findUserByCondition(condition); } return JSON.parseObject(userJson, User.class); } @Override public User createUser(User user) { // 密码加密 String password = Encrypt.SHA512(UserConstant.SALT + user.getUsername() + user.getPassword()); user.setId(new Long(System.currentTimeMillis()).intValue()); user.setPassword(password); try { int affect = userDao.insertUser(user); if (affect != 1) { return null; } return user; } catch (Exception e) { e.printStackTrace(); } return null; } @Override public User findUserByUsername(String username) { User user = new User(); user.setUsername(username); return userDao.findUserByCondition(user); } @Override @Transactional public String register(User user) { // 密码加密 String password = Encrypt.SHA512(UserConstant.SALT + user.getUsername() + user.getPassword()); user.setId(new Long(System.currentTimeMillis()).intValue()); user.setPassword(password); try { // 插入用户 int affect = userDao.insertUser(user); if (affect != 1) { return "添加用户失败"; } } catch (Exception e) { e.printStackTrace(); return "添加用户失败"; } return null; } |

源码还是放在了上面那个项目地址中