资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/springboot_database项目介绍

springboot_database项目介绍

tracymac7 / 740人阅读

摘要：操作操作对象设置缓存时间有效时间等待等待设置为的时候后面可能取到值，的过期时间有延迟注意操作对象时对象需要实现序列化接口两者操作互不影响生成为生称为数据库文件相关相关相关相关相关相关相关相关相关相关相关相关

springboot_database

springboot1.5.7集成mybatis、jpa、redis、mongodb，对不同数据库进行操作的实例
项目代码获取：https://github.com/pysasuke/s...

项目结构 main dao:数据库交互层

jpa:jpa与mysql数据库交互类

</>复制代码 
  1. public interface JpaUserRepository extends JpaRepository {
  2.     //jpa有默认实现类似findBy*(支持*And*)方法，其中*号为实体属性名(名称写的不对会报错哦)
  3.     JpaUser findByUsername(String username);
  4.     @Query("select count(u.id) from JpaUser u")
  5.     long count();
  6.     @Query("select u from JpaUser u where u.id=:id")
  7.     JpaUser findUserById(@Param("id") long id);
  8. }

mongo:mongodb数据库交互类

</>复制代码 
  1. public interface MongoUserRepository extends MongoRepository {
  2.     //有默认实现类似findBy*(支持*And*)方法，其中*号为实体属性名
  3.     MgUser findByNickname(String nickname);
  4.     //根据id为条件搜索(默认实现的findOne方法是以mongodb中ObjectId为条件的)
  5.     MgUser findById(Long id);
  6. }

mybatis:mybatis与mysql数据库交互类

</>复制代码 
  1. //@Mapper(SpringbootDatabaseApplication类中使用了@MapperScan注解,故此处可以省略)
  2. public interface TuserMapper {
  3.     int deleteByPrimaryKey(Long id);
  4.     int insert(Tuser record);
  5.     Tuser selectByPrimaryKey(Long id);
  6.     Tuser selectByUserName(String username);
  7.     int updateByPrimaryKeySelective(Tuser record);
  8. }
entity:实体对象层

jpa:jpa操作mysql相关实体对象

</>复制代码 
  1. @Data
  2. @Entity//标记这个类为数据库表映射实体
  3. @Table(name="user")//对应数据库表名
  4. public class JpaUser implements Serializable{
  5.     @Id//标记为主键
  6.     @GeneratedValue//标记主键自增
  7.     private Long id;
  8.     private String username;
  9.     private String password;
  10.     private String mobile;
  11.     private String email;
  12. }

mongo:mongodb相关实体对象

</>复制代码 
  1. @Data
  2. //需要与mongo中对象(文档)名一致
  3. public class MgUser {
  4.     @Id
  5.     private ObjectId _id;    //插入mongo时会自动生成_id，如果不加这个字段则会把id属性当成_id
  6.     @Field
  7.     private Long id;
  8.     private String nickname;
  9.     private String phone;
  10. }

mybatis:mybatis操作mysql相关实体对象

</>复制代码 
  1. @Data
  2. public class Tuser {
  3.     private Long id;
  4.     private String username;
  5.     private String password;
  6.     private String mobile;
  7.     private String email;
  8. }

redis:redis相关实体对象

</>复制代码 
  1. //redisTemplate操作对象时对象需要实现序列化接口
  2. @Data
  3. public class Person implements Serializable{
  4.     private Long serialVersionUID=1L;
  5.     private Long id;
  6.     private String username;
  7.     private String password;
  8. }
SpringbootDatabaseApplication:springboot启动类 
</>复制代码 
  1. @SpringBootApplication
  2. // mapper 接口类扫描包配置(可以省去dao层类上注解@Mapper)
  3. @MapperScan("com.py.springboot_database.dao.mybatis")
  4. public class SpringbootDatabaseApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(SpringbootDatabaseApplication.class, args);
  7.     }
  8. }
resources

mapper:mybatis实体类映射文件存放包

application.properties:springboot配置文件

</>复制代码 
  1. ## 数据源配置
  2. spring.datasource.url=jdbc:mysql://localhost:3306/springboot_database?useUnicode=true&characterEncoding=utf8
  3. spring.datasource.username=root
  4. spring.datasource.password=py123456
  5. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
  6. ## Mybatis 配置
  7. ##指向实体类包路径
  8. mybatis.typeAliasesPackage=com.py.springboot_database.entity.mybatis
  9. ##配置为 classpath 路径下 mapper 包下，* 代表会扫描所有 xml 文件
  10. mybatis.mapperLocations=classpath:mapping/*.xml
  11. ## mongodb配置
  12. spring.data.mongodb.uri=mongodb://localhost:27017/test
  13. ## Redis 配置
  14. ## Redis数据库索引（默认为0）
  15. spring.redis.database=0
  16. ## Redis服务器地址
  17. spring.redis.host=127.0.0.1
  18. ## Redis服务器连接端口
  19. spring.redis.port=6379
  20. ## Redis服务器连接密码（默认为空）
  21. spring.redis.password=
  22. ## 连接池最大连接数（使用负值表示没有限制）
  23. spring.redis.pool.max-active=8
  24. ## 连接池最大阻塞等待时间（使用负值表示没有限制）
  25. spring.redis.pool.max-wait=-1
  26. ## 连接池中的最大空闲连接
  27. spring.redis.pool.max-idle=8
  28. ## 连接池中的最小空闲连接
  29. spring.redis.pool.min-idle=0
  30. ## 连接超时时间（毫秒）
  31. spring.redis.timeout=0
test

jpa:TestJpa类,jpa操作mysql对象增删改查操作测试

</>复制代码 
  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @SpringBootTest(classes = SpringbootDatabaseApplication.class)
  3. public class TestJpa {
  4.     @Autowired
  5.     private JpaUserRepository jpaUserRepository;
  6.     @Test
  7.     public void testInsert() {
  8.         long countBefore =jpaUserRepository.count();
  9.         JpaUser jpaUser = generateJpaUser();
  10.         jpaUserRepository.save(jpaUser);
  11.         long countAfter =jpaUserRepository.count();
  12.         Assert.assertEquals(++countBefore,countAfter);
  13.     }
  14.     @Test
  15.     public void testSelect() {
  16.         JpaUser jpaUser = generateJpaUser();
  17.         /*
  18.         插入成功后id会有值(mysql数据库生成的)
  19.         前提是：
  20.         1.数据库主键设置为自动增长
  21.         2.实体对象主键属性上有注解@Id和@GeneratedValue
  22.          */
  23.         jpaUserRepository.save(jpaUser);
  24.         JpaUser selectedJpaUser = jpaUserRepository.findOne(jpaUser.getId());
  25.         Assert.assertNotNull(selectedJpaUser);
  26.         Assert.assertEquals(jpaUser, selectedJpaUser);
  27.     }
  28.     @Test
  29.     public void testUpdate() {
  30.         JpaUser jpaUser = generateJpaUser();
  31.         jpaUserRepository.save(jpaUser);
  32.         JpaUser selectedJpaUser = jpaUserRepository.findOne(jpaUser.getId());
  33.         Assert.assertNotNull(selectedJpaUser);
  34.         selectedJpaUser.setPassword("654321");
  35.         //保存修改后的对象，相当于update操作
  36.         jpaUserRepository.save(selectedJpaUser);
  37.         //findOne(默认实现)方法与findUserById(自己实现)都是根据id查找
  38.         JpaUser updatedJpaUser = jpaUserRepository.findUserById(selectedJpaUser.getId());
  39.         Assert.assertNotNull(updatedJpaUser);
  40.         Assert.assertEquals(selectedJpaUser.getPassword(), updatedJpaUser.getPassword());
  41.     }
  42.     @Test
  43.     public void testDelete() {
  44.         JpaUser jpaUser = generateJpaUser();
  45.         jpaUserRepository.save(jpaUser);
  46.         jpaUserRepository.delete(jpaUser.getId());
  47.         JpaUser selectedJpaUser = jpaUserRepository.findUserById(jpaUser.getId());
  48.         Assert.assertNull(selectedJpaUser);
  49.     }
  50.     private JpaUser generateJpaUser() {
  51.         JpaUser jpaUser = new JpaUser();
  52.         jpaUser.setUsername("zhangsan");
  53.         jpaUser.setPassword("123456");
  54.         jpaUser.setMobile("13666666666");
  55.         jpaUser.setEmail("123456@qq.com");
  56.         return jpaUser;
  57.     }
  58. }

mongo:TestMongo类,mongodb测试

</>复制代码 
  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @SpringBootTest(classes = SpringbootDatabaseApplication.class)
  3. public class TestMongo {
  4.     @Autowired
  5.     private MongoUserRepository userRepository;
  6.     @Test
  7.     public void test() {
  8.         MgUser mgUser = new MgUser();
  9.         mgUser.setId(1L);
  10.         mgUser.setNickname("pysasuke");
  11.         mgUser.setPhone("18650140605");
  12.         //插入成功后_id属性有值(mongo数据库生成的)
  13.         userRepository.insert(mgUser);
  14.         //该方法使用的是mongodb中ObjectId为条件的
  15. //        MgUser selectMgUser = userRepository.findOne(1L);
  16. //        MgUser selectMgUser = userRepository.findByNickname("pysasuke");
  17.         MgUser selectMgUser = userRepository.findById(1L);
  18.         Assert.assertEquals(mgUser.getId(), selectMgUser.getId());
  19.     }
  20. }

mybatis:TestMybatis类,mybatis操作mysql对象增删改查测试

</>复制代码 
  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @SpringBootTest(classes = SpringbootDatabaseApplication.class)
  3. public class TestMybatis {
  4.     @Autowired
  5.     private TuserMapper tuserMapper;
  6.     @Test
  7.     public void testInsert() {
  8.         Tuser tuser = generateTuser();
  9.         int row = tuserMapper.insert(tuser);
  10.         Assert.assertEquals(1, row);
  11.     }
  12.     @Test
  13.     public void testSelect() {
  14.         Tuser tuser = generateTuser();
  15.         /*
  16.         插入成功后id会有值(mysql数据库生成的)
  17.         前提是：
  18.         1.主键设置为自动增长
  19.         2.xml中insert语句设置有:useGeneratedKeys="true" keyProperty="id"
  20.          */
  21.         int row = tuserMapper.insert(tuser);
  22.         Assert.assertEquals(1, row);
  23.         Tuser selectedTuser = tuserMapper.selectByPrimaryKey(tuser.getId());
  24.         Assert.assertNotNull(selectedTuser);
  25.         Assert.assertEquals(tuser, selectedTuser);
  26.     }
  27.     @Test
  28.     public void testUpdate() {
  29.         Tuser tuser = generateTuser();
  30.         int row = tuserMapper.insert(tuser);
  31.         Assert.assertEquals(1, row);
  32.         Tuser selectedTuser = tuserMapper.selectByPrimaryKey(tuser.getId());
  33.         Assert.assertNotNull(selectedTuser);
  34.         selectedTuser.setPassword("654321");
  35.         tuserMapper.updateByPrimaryKeySelective(selectedTuser);
  36.         Tuser updatedTuser = tuserMapper.selectByPrimaryKey(selectedTuser.getId());
  37.         Assert.assertNotNull(updatedTuser);
  38.         Assert.assertEquals(selectedTuser.getPassword(), updatedTuser.getPassword());
  39.     }
  40.     @Test
  41.     public void testDelete() {
  42.         Tuser tuser = generateTuser();
  43.         int row = tuserMapper.insert(tuser);
  44.         Assert.assertEquals(1, row);
  45.         tuserMapper.deleteByPrimaryKey(tuser.getId());
  46.         Tuser selectedTuser = tuserMapper.selectByPrimaryKey(tuser.getId());
  47.         Assert.assertNull(selectedTuser);
  48.     }
  49.     private Tuser generateTuser() {
  50.         Tuser tuser = new Tuser();
  51.         tuser.setUsername("zhangsan");
  52.         tuser.setPassword("123456");
  53.         tuser.setMobile("13666666666");
  54.         tuser.setEmail("123456@qq.com");
  55.         return tuser;
  56.     }
  57. }

redis:TestRedis类,redis测试

</>复制代码 
  1. /*
  2. 当redis数据库里面本来存的是字符串数据或者要存取的数据就是字符串类型数据的时候，
  3. 那么使用StringRedisTemplate即可，
  4. 但是如果数据是复杂的对象类型，而取出的时候又不想做任何的数据转换，直接从Redis里面取出一个对象，
  5. 那么使用RedisTemplate是更好的选择。
  6.  */
  7. @RunWith(SpringJUnit4ClassRunner.class)
  8. @SpringBootTest(classes = SpringbootDatabaseApplication.class)
  9. public class TestRedis {
  10.     //操作String
  11.     @Autowired
  12.     private StringRedisTemplate stringRedisTemplate;
  13.     //操作对象
  14.     @Autowired
  15.     private RedisTemplate redisTemplate;
  16.     @Test
  17.     public void testPutString() {
  18.         stringRedisTemplate.opsForValue().set("testPutString", "123456");
  19.     }
  20.     @Test
  21.     public void tesGetString() {
  22.         stringRedisTemplate.opsForValue().set("tesGetString", "123456");
  23.         String str = stringRedisTemplate.opsForValue().get("tesGetString");
  24.         Assert.assertEquals("123456", str);
  25.         //设置缓存时间
  26.         stringRedisTemplate.opsForValue().set("tesGetString", "123456", 1000, TimeUnit.MILLISECONDS);//有效时间1s
  27.         try {
  28.             Thread.sleep(2000);//等待2s(等待设置为1s的时候后面可能取到值，redis的过期时间有延迟)
  29.         } catch (InterruptedException e) {
  30.             e.printStackTrace();
  31.         }
  32.         str = stringRedisTemplate.opsForValue().get("tesGetString");
  33.         Assert.assertNull(str);
  34.     }
  35.     //注意：redisTemplate操作对象时对象需要实现序列化接口
  36.     @Test
  37.     public void testObject() {
  38.         Person person = generatePerson();
  39.         redisTemplate.opsForValue().set("testObject:" + person.getUsername(), person, 600);
  40.     }
  41.     @Test
  42.     public void tesGetObject() {
  43.         Person person = generatePerson();
  44.         redisTemplate.opsForValue().set("tesGetObject:" + person.getUsername(), person);
  45.         Person cachePerson = (Person) redisTemplate.opsForValue().get("tesGetObject:" + person.getUsername());
  46.         Assert.assertEquals(person, cachePerson);
  47.     }
  48.     @Test
  49.     public void tesDeleteCache() {
  50.         stringRedisTemplate.opsForValue().set("tesDeleteCache", "123456");
  51.         String cacheStr = stringRedisTemplate.opsForValue().get("tesDeleteCache");
  52.         Assert.assertEquals("123456", cacheStr);
  53.         stringRedisTemplate.delete("tesDeleteCache");
  54.         String DeleteStr = stringRedisTemplate.opsForValue().get("tesDeleteCache");
  55.         Assert.assertNull(DeleteStr);
  56.     }
  57.     //两者操作互不影响
  58.     @Test
  59.     public void testStrRedisTempAndRedisTemp(){
  60.         Person person = generatePerson();
  61.         //生成key为：xACxEDx00x05tx00x04test
  62.         redisTemplate.opsForValue().set("testDiff", person);
  63.         //生称key为：test
  64.         stringRedisTemplate.opsForValue().set("testDiff", "123456");
  65.         String cacheStr = stringRedisTemplate.opsForValue().get("testDiff");
  66.         Assert.assertEquals("123456", cacheStr);
  67.         Person cachePerson = (Person) redisTemplate.opsForValue().get("testDiff");
  68.         Assert.assertEquals(person, cachePerson);
  69.     }
  70.     
  71.     private Person generatePerson() {
  72.         Person person = new Person();
  73.         person.setId(1L);
  74.         person.setUsername("wangwu");
  75.         person.setPassword("123456");
  76.         return person;
  77.     }
  78. }
deploy

update.sql:数据库sql文件

</>复制代码 
  1. CREATE DATABASE springboot_database;
  2. USE springboot_database;
  3. DROP TABLE IF EXISTS `user` ;
  4. CREATE TABLE `user` (
  5.   `id` bigint(20) NOT NULL AUTO_INCREMENT,
  6.   `username` varchar(50) NOT NULL,
  7.   `password` varchar(50) NOT NULL,
  8.   `mobile` varchar(20) NOT NULL,
  9.   `email` varchar(50) NOT NULL,
  10.   PRIMARY KEY (`id`)
  11. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
pom.xml 
</>复制代码 
  1.     
  2.         
  3.             org.springframework.boot
  4.             spring-boot-starter
  5.         
  6.         
  7.             org.springframework.boot
  8.             spring-boot-starter-test
  9.             test
  10.         
  11.         
  12.         
  13.             org.projectlombok
  14.             lombok
  15.         
  16.         
  17.         
  18.         
  19.             org.springframework.boot
  20.             spring-boot-starter-data-mongodb
  21.         
  22.         
  23.         
  24.         
  25.             org.springframework.boot
  26.             spring-boot-starter-redis
  27.             1.4.7.RELEASE
  28.         
  29.         
  30.         
  31.         
  32.             org.mybatis.spring.boot
  33.             mybatis-spring-boot-starter
  34.             1.3.1
  35.         
  36.         
  37.         
  38.         
  39.             mysql
  40.             mysql-connector-java
  41.         
  42.         
  43.         
  44.         
  45.             org.springframework.boot
  46.             spring-boot-starter-data-jpa
  47.         
  48.         
  49.         
  50.
云服务器 GPU云服务器 开源项目介绍 springboot_database 自我介绍 平台介绍

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/19114.html

相关文章

  • 一个JAVA渣渣的校招成长记，附BAT美团网易等20家面经总结

    摘要：作者重庆森林链接来源牛客网整个三月份通过牛客网和网友分享的经验学到了很多东西，现在反馈一下我的面试经历，希望对同学们有帮助。个人情况大三本方向渣硕，经过实验室学长内推，于三月底完成面试。校招是实力和运气的结合，缺一不可。 欢迎关注我的微信公众号：Java面试通关手册（坚持原创，分享美文，分享各种Java学习资源，面试题，以及企业级Java实战项目回复关键字免费领取）：showImg(h...

    mozillazg 评论0 收藏0

  • 程序员面试时这样介绍自己的项目经验，成功率能达到98.99%

    面试时7份靠能力，3份靠技能，而刚开始时的介绍项目又是技能中的重中之重，决定一次面试的成败，那么面试时如果介绍自己的项目呢？ 1、在面试前准备项目描述 别害怕，因为面试官什么都不知道，面试官是人，不是神，拿到你的简历的时候，是没法核实你的项目细节的。更何况，你做的项目是以月为单位算的，而面试官最多用30分钟来从你的简历上了解你的项目经验，所以你对项目的熟悉程度要远远超过面试官，所以你一点也不用紧张...

    ad6623 评论0 收藏0

  • 程序员面试时这样介绍自己的项目经验，成功率能达到98.99%

    面试时7份靠能力，3份靠技能，而刚开始时的介绍项目又是技能中的重中之重，决定一次面试的成败，那么面试时如果介绍自己的项目呢？ 1、在面试前准备项目描述 别害怕，因为面试官什么都不知道，面试官是人，不是神，拿到你的简历的时候，是没法核实你的项目细节的。更何况，你做的项目是以月为单位算的，而面试官最多用30分钟来从你的简历上了解你的项目经验，所以你对项目的熟悉程度要远远超过面试官，所以你一点也不用紧张...

    shadowbook 评论0 收藏0

发表评论

登陆后可评论

0条评论

tracymac7

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<