springboot2.0集成dbcp2连接mysql

淡淡的烟草味﹌ 2022-02-27 15:12 202阅读 0赞

Dev environment :

maven 3.54 、mysql 8、jdk 1.8 、 springboot 2.0

> 项目 DEMO 如下：  
> [https://github.com/medoo-Ai/springbootMYSQL][https_github.com_medoo-Ai_springbootMYSQL]

1、创建maven项目，引入依赖，配置yml 配置文件

2、 监听数据库连接池的类型，在 database 包下

@Component
    public class DataSourceShow implements ApplicationContextAware { 
    
        ApplicationContext applicationContext = null;
         // Spring 容器会自动调用这个方法，注入 Spring IoC 容器
        @Override
        public void setApplicationContext(ApplicationContext applicationContext)
                throws BeansException { 
            this.applicationContext = applicationContext;
            DataSource dataSource = applicationContext.getBean(DataSource.class);
            System.out.println(dataSource.getClass().getName());
        }
    }

2、依据table 创建 pojo ，引入 lombok ,并对其方访问

> 可引入逆向工程生成  
> [https://blog.csdn.net/weixin\_42323802/article/details/83050762][https_blog.csdn.net_weixin_42323802_article_details_83050762]  
> lombok 可参考  
> [https://blog.csdn.net/weixin\_42323802/article/details/84547988][https_blog.csdn.net_weixin_42323802_article_details_84547988]

@Getter
    @Setter
    @TosString
    public class User { 
        private Long id = null;    
        private String userName = null;
        <strong>private SexEnum sex = null;// 枚举</strong>
        private String note = null;
    }

3、 创建枚举，对数据库进行操作，可引入事务进行测试

2019.03.28  23：17  刚下班 ，洗了澡没吃饭就这个点了

@Service
    public class UsserServiceImpl implements UserService { 
    
        @Autowired
        private JdbcTemplate jdbcTemplate;
    
        // 集
        private RowMapper<User> getRowMapper(){ 
            RowMapper<User> userRowMapper=(ResultSet rs,int row)->{ 
                User user = new User();
                user.setId(rs.getLong("id"));
                user.setAge(rs.getInt("age"));
                user.setName(rs.getString("name"));
                user.setSexEnum(SexEnum.getEnumById(rs.getInt("sex")));
                return user;
            };
            return userRowMapper;
        }
    
        @Override
        public int insert(User user) { 
            String sql="insert into t_user values(null, ? , ?, ?)";
            return this.jdbcTemplate.update(sql, user.getId(),user.getName(),user.getAge(),user.getSexEnum().getId());
        }
    
        @Override
        public int update(User user) { 
            String sql="update t_user set name=? , age=?, sex=?"+"where id=?";
            return this.jdbcTemplate.update(sql, user.getName(),user.getAge(),user.getSexEnum().getId(),user.getId());
        }
    
        @Override
        public User selectUserById(Long uid) { 
            Object params=new Object[]{ uid};
            String sql="select * from t_user where id=?";
            return this.jdbcTemplate.queryForObject(sql, (Object[]) params,getRowMapper());
        }
    
        @Override
        public List<User> selectUserListByAgeOrName(User user) { 
            Object params=new Object[]{ user.getName(),user.getAge()};
            String sql="select * from t_user"+"where name like concat ('%',?,'%')"+"and age like concat('%',?,'%')";
            return jdbcTemplate.query(sql, (Object[]) params,getRowMapper());
        }
    
        @Override
        public int deleteById(Long uid) { 
            Object params=new Object[]{ uid};
            String sql="select * from t_user where id=?";
            return jdbcTemplate.update(sql, params);
        }
    }

当然以上写法 基于 jdbctemplate 执行SQL 不断创建链接，这样效率低下，  
可以使用回调函数  
StatementCallback 和 ConnectionCallback 这样一个连接执行多个SQL

> 具体的  
> 这里展示一个实现 ，另一个在gitHub 体现：  
> [https://github.com/medoo-Ai/springbootMYSQL][https_github.com_medoo-Ai_springbootMYSQL]

/** * 实现StatementCallback 接口 * @param id * @return */
        public User getUser(Long id) { 
            User result=this.jdbcTemplate.execute((Statement sta) -> { 
                String sql = "select count(*) totalAmt from t_user where id= " + id;
                ResultSet resultSet = sta.executeQuery(sql);
                while (resultSet.next()) { 
                    int totalAmt = resultSet.getInt("totalAmt");
                    System.out.println("totalAmt = " + totalAmt);
                }
    
                String sql2 = "select * total from t_user where id= " + id;
                ResultSet rst = sta.executeQuery(sql);
                User user=null;
                while (rst.next()) { 
                    int row = rst.getRow();
                    user = getRowMapper().mapRow(rst, row);
                }
                return user;
            });
            return result;
        }

4、 JPA 引入 以及定义 枚举类的转换器

@Getter
    @Setter
    @ToString
    @Entity(name = "user")
    @Table(name = "t_user")
    public class User { 
    
        @Id
        @GeneratedValue(strategy= GenerationType.IDENTITY)
        private Long id;
        @Column(name = "name")
        private String name;
        @Column(name = "age")
        private int age;
        @Convert(converter = SexEnumConverter.class )
        private SexEnum sexEnum;
    }

SexEnumConverter 转换器 实现 AttributeConverter<X，Y> 接口  
@Convert(converter = SexEnumConverter.class ) 映射枚举类 的转换接口，转换枚举类和mysql 数据库的字段映射；

public class SexEnumConverter  implements AttributeConverter<SexEnum,Integer> { 
    
        @Override
        public Integer convertToDatabaseColumn(SexEnum sexEnum) { 
            return sexEnum.getId();
        }
    
        @Override
        public SexEnum convertToEntityAttribute(Integer integer) { 
            return SexEnum.getEnumById(integer);
        }
    }

4.1 、JpaRepository 作为顶级接口 所提供的哪些功能  
![1][]  
这样看来 应该很清楚了。  
可以CURD ，分页排序 ，还有通过 Example 来进行查询；

@EnableJpaRepositories(basePackages = "com.demo.spring.jpa")
    @EntityScan(basePackages = "com.demo.spring.bean")
    @SpringBootApplication(scanBasePackages = { "com.demo.spring"})
    public class SpringAppMain { 
        public static void main(String[] args) { 
            SpringApplication.run(SpringAppMain.class, args);
            System.out.println("服务已经启动");
        }
    }

配置好启动类，启动进行测试、

03.30  配置 mybatis   插件

1、springboot 项目中，怎么去配置一个自定义的 myabtis 插件呢  
springboot 的properties 配置文件中，去指定 项目的配置XML文件，在XML 文件中 把 我们自己开发的插 件 配置上去；；

@Intercepts({ 
    		@Signature(type = StatementHandler.class, method = "prepare", args = {  Connection.class, Integer.class }) })
    public class MyPlugin implements Interceptor { 
    
    	Properties properties = null;
    
    	// 拦截方法逻辑
    	@Override
    	public Object intercept(Invocation invocation) throws Throwable { 
    		System.out.println("插件拦截方法......");
    		return invocation.proceed();
    	}
    
    	// 生成MyBatis拦截器代理对象
    	@Override
    	public Object plugin(Object target) { 
    		return Plugin.wrap(target, this);
    	}
    
    	// 设置插件属性
    	@Override
    	public void setProperties(Properties properties) { 
    		this.properties = properties;
    	}
    }

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
    <configuration>
       
        <plugins>
            <plugin interceptor="com.demo.spring.plugin.MyPlugin">
                <property name="key1" value="value1"/>
                <property name="key2" value="value2"/>
                <property name="key2" value="value2"/>
            </plugin>
        </plugins>
    </configuration>

2、这里，说下 使用注解的方法 添加mybatis 插件

在main 启动类中 添加 插件；  
启用spring的生命周期，启动插件；

@Autowired
        SqlSessionFactory sqlSessionFactory = null;
    
        @PostConstruct
        public void initMyBatis() { 
            // 插件实例
            Interceptor plugin = new MyPlugin();
            // 设置插件属性
            Properties properties = new Properties();
            properties.setProperty("key1", "value1");
            properties.setProperty("key2", "value2");
            properties.setProperty("key3", "value3");
            plugin.setProperties(properties);
            // 在 sqlSessionFactory 中添加插件
            sqlSessionFactory.getConfiguration().addInterceptor(plugin);
        }

@PostConstruct 自定义初始化方法 ， 调用 properties 。 set（） 方法，把自定义的值 set 进去；

[https_github.com_medoo-Ai_springbootMYSQL]: https://github.com/medoo-Ai/springbootMYSQL
[https_blog.csdn.net_weixin_42323802_article_details_83050762]: https://blog.csdn.net/weixin_42323802/article/details/83050762
[https_blog.csdn.net_weixin_42323802_article_details_84547988]: https://blog.csdn.net/weixin_42323802/article/details/84547988
[1]: /images/20220227/09ec8d81d52b45388ebabe1dc6cf6fa6.png