MyBatis系列-动态连接数据库

素颜马尾好姑娘i 2022-02-02 23:39 337阅读 0赞

# 前言 #

MyBatis是目前java项目连接数据库的最流行的orm框架了。常用的使用方法是配置datasource，编写dao和mapper，最后通过依赖注入调用dao的方法来操作数据。本篇使用MyBatis来动态生成MyBatis的对象，动态配置数据库连接操作数据库。

# 动态数据库连接 #

使用MyBaits常规方式是在xml或者properties来配置MyBatis，但是这样会把配置参数写死。如果想要动态访问数据库，我们能自己手动实例化MyBatis对象。

## DataSource对象 ##

还记得我们在经常在xml配置文件中，配置一个Datasource对象，设置数据连接相关参数。这里我们使用代码动态实例化一个PooledDataSource

PooledDataSource dataSource = new PooledDataSource();
    dataSource.setDriver("com.mysql.cj.jdbc.Driver");
    dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/test");
    dataSource.setUsername("root");
    dataSource.setPassword("123456");

## mapper路径 ##

ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
    Resource[] resources = resolver.getResources("classpath:/mapper/*Mapper.xml");

## MybatisSqlSessionFactoryBean对象 ##

MybatisSqlSessionFactoryBean sqlSessionFactoryBean = new MybatisSqlSessionFactoryBean();
    sqlSessionFactoryBean.setMapperLocations(resources);
    sqlSessionFactoryBean.setDataSource(dataSource);

## SqlSessionFactory对象 ##

SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBean.getObject();

## SqlSession对象 ##

记住，这里的sqlsession生成后，请保存到一个HashMap就像一个数据库连接池一样，可以反复使用。否则，每次数据库操作都会打开一个新的数据库连接，造成数据库连接超限，导致数据库瘫痪。

SqlSession sqlsession = sqlSessionFactory.openSession();
    // 调用数据库操作方法
    sqlsession.close()

我们平常使用MyBatis时，会在xml或者properties文件中配置的参数，然后MyBatis会使用这些参数实例化以上对象。

# 动态sql语句 #

动态配置了MyBatis的数据库连接，并生成MyBatis对象。接下来，就是常规的利用MyBatis的Mapper模板来实现数据的增删改查了。

## DynamicMapper类 ##

public interface DynamicMapper { 
        List<Map<String, Object>> selectSql(@Param("tableName") String tableName, @Param("fields") String fields, @Param("whereCondition") String whereCondition, @Param("orderCondition") String orderCondition);
    
        Integer insertSql(@Param("tableName") String tableName, @Param("result") String result);
    
        Integer updateSql(@Param("tableName") String tableName, @Param("result") String result, @Param("whereCondition") String whereCondition);
    
        Integer deleteSql(@Param("tableName") String tableName, @Param("whereCondition") String whereCondition);
    }

## DynamicMapper.xml ##

<mapper namespace="com.camellibby.pangu.openapi.mapper.DynamicMapper">
    	<select id="selectSql" resultType="java.util.LinkedHashMap">
    		select ${fields} from ${tableName}
    		<if test="whereCondition != null and whereCondition != ''">
    			where ${whereCondition}
    		</if>
    		<if test="orderCondition != null and orderCondition != ''">
    			order by ${orderCondition}
    		</if>
    	</select>
    
    	<insert id="insertSql">
    		insert into ${tableName} ${result}
    	</insert>
    
    	<update id="updateSql">
    		UPDATE ${tableName} SET ${result} WHERE ${whereCondition}
    	</update>
    
    	<delete id="deleteSql">
    		delete from ${tableName} WHERE ${whereCondition}
    	</delete>
    </mapper>

## DynamicMapper动态运行sql语句 ##

DynamicMapper dynamicMapper = sqlsession.getMapper(DynamicMapper.class);
    List<Map<String, Object>> users = dynamicMapper.selectSql(
    		"users",
    		"username, password, enabled",
    		"enabled=0",
    		"username"
    );
    users.forEach(user ->
            user.keySet().forEach(key ->
    			System.out.println(key + ":" + user.get(key))
    		)
    );

# 测试 #

运行测试用例，进行sql查询，输出如下

03:32:46.245 [main] DEBUG org.mybatis.spring.transaction.SpringManagedTransaction - JDBC Connection [com.mysql.cj.jdbc.ConnectionImpl@68044f4] will not be managed by Spring
    03:32:46.260 [main] DEBUG DynamicMapper.selectSql - ==>  Preparing: select username, password, enabled from users where enabled=0 order by username 
    03:32:46.338 [main] DEBUG DynamicMapper.selectSql - ==> Parameters: 
    03:32:46.385 [main] DEBUG DynamicMapper.selectSql - <==      Total: 6
    username:Chandler
    password:{bcrypt}$2a$10$/8MMuGgPbNXoiMgvS3uabuQiRMW3f96wLP/ifZ3VcSHo28OuzB8Hu
    enabled:false
    username:Joey
    password:{bcrypt}$2a$10$/8MMuGgPbNXoiMgvS3uabuQiRMW3f96wLP/ifZ3VcSHo28OuzB8Hu
    enabled:false
    username:Monica
    password:{bcrypt}$2a$10$/8MMuGgPbNXoiMgvS3uabuQiRMW3f96wLP/ifZ3VcSHo28OuzB8Hu
    enabled:false
    username:Phoebe
    password:{bcrypt}$2a$10$/8MMuGgPbNXoiMgvS3uabuQiRMW3f96wLP/ifZ3VcSHo28OuzB8Hu
    enabled:false
    username:Rachel
    password:{bcrypt}$2a$10$/8MMuGgPbNXoiMgvS3uabuQiRMW3f96wLP/ifZ3VcSHo28OuzB8Hu
    enabled:false
    username:Ross
    password:{bcrypt}$2a$10$/8MMuGgPbNXoiMgvS3uabuQiRMW3f96wLP/ifZ3VcSHo28OuzB8Hu
    enabled:false

和数据库查询结果一致，结果如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NhbWVsODQ_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NhbWVsODQ_size_16_color_FFFFFF_t_70]: /images/20220203/e5936d3171ce419daa9c4134d6ec91a2.png

发表评论取消回复

表情：

评论列表（有 0 条评论，337人围观）

还没有评论，来说两句吧...

相关阅读

相关 [MyBatis系列③]动态SQL

目录 1、简介 2、if标签 3、foreach标签 4、SQL抽取 -------------------- > ⭐MyBatis系列①：[增删改查][Link

秒速五厘米/ 2024年03月24日 20:57/ 0 赞/ 52 阅读

相关【Mybatis系列】动态sql

介绍：什么是动态SQL：动态Sql指的是根据不同的查询条件，生成不同的sql语句我们之前写的sql语句都是比较简单的，如果有比较复

你的名字/ 2022年11月30日 15:51/ 0 赞/ 143 阅读

相关 mysql动态连接数据库

1.配置xml文件 applicationContext.xml <bean id="defaultDataSource" class="org.apache

矫情吗；*/ 2022年08月13日 11:54/ 0 赞/ 199 阅读

相关 MyBatis连接数据库

MyBatis连接数据库三个步骤 1.创建工程 2.加入相关jar包 3.将MyBatis的配置xml放到src下面这里主要讲步骤3: 首先需要在src文

你的名字/ 2022年07月13日 01:50/ 0 赞/ 181 阅读

相关 SpringBoot - MyBatis 连接数据库

> Spring Boot中集成MyBatis，可以选用基于注解的方式（下篇会介绍简单的使用），也可以选择xml文件配置的方式。通过对两者进行实际的使用，还是建议使用XML的方

我就是我/ 2022年05月29日 01:39/ 0 赞/ 243 阅读

相关 Mybatis的Mapper动态代理方式连接mysql数据库

Mapper接口开发方法只需要程序员编写Mapper接口（相当于Dao接口），由Mybatis框架根据接口定义创建接口的动态代理对象，代理对象的方法体同上边Da

女爷i/ 2022年05月17日 08:10/ 0 赞/ 292 阅读

相关 IDEA+Mybatis连接数据库（一）

首先创建Maven项目，在pom.xml中添加依赖： <dependency> <groupId>org.mybatis</groupId>

￡神魔★判官ぃ/ 2022年03月01日 07:28/ 0 赞/ 451 阅读

相关 Mybatis系列八：动态SQL

创建EmployeeMapperDynamicSQL接口 public interface EmployeeMapperDynamicSQL {

旧城等待，/ 2022年02月16日 01:15/ 0 赞/ 313 阅读

相关 Mybatis数据库连接问题

很有可能是数据库驱动和MySql的版本没有连上我就是驱动的版本为mysql-connector-java-5.0.3-bin.jar 但是我的MySql是8.0的，驱

た入场券/ 2022年02月04日 01:21/ 0 赞/ 238 阅读

相关 MyBatis系列-动态连接数据库

前言 MyBatis是目前java项目连接数据库的最流行的orm框架了。常用的使用方法是配置datasource，编写dao和mapper，最后通过依赖注入调用dao的方

素颜马尾好姑娘i/ 2022年02月02日 23:39/ 0 赞/ 338 阅读