一、配置Mybatis
第一步:在pom.xml中导入相关依赖
<!-- Mybatis框架 --> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.5.0</version> </dependency> <!-- MyBatis整合Spring --> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>2.0.1</version> </dependency> <!-- Spring JDBC依赖,必须与其它Spring依赖使用完全相同的版本 --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>5.2.2.RELEASE</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.25</version> </dependency>
第二步:创建在resources文件夹下创建jdbc.properties并配置连接数据库的配置(根据自己的数据库)
db.driver=com.mysql.cj.jdbc.Driver db.url=jdbc:mysql://localhost:3306/mysql?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true db.username=root db.password=root db.maxActive=10 db.initialSize=2
第三步:编写Mybatis的配置文件(根据自己的数据库配置文件)
@PropertySource("classpath:jdbc.properties") public class MyBatisConfig { @Bean public DataSource dataSource( @Value("${db.driver}") String driver, @Value("${db.url}") String url, @Value("${db.username}") String username, @Value("${db.password}") String password, @Value("${db.maxActive}") int maxActive, @Value("${db.initialSize}") int initialSize) { DruidDataSource ds = new DruidDataSource(); ds.setDriverClassName(driver); ds.setUrl(url); ds.setUsername(username); ds.setPassword(password); ds.setMaxActive(maxActive); ds.setInitialSize(initialSize); return ds; } }
二、测试,查看Mybatis配置类是否配置成功(根据自己的数据库来配置sql语句)
public class TestConfig { AnnotationConfigApplicationContext ctx; @Before public void berfore(){ ctx = new AnnotationConfigApplicationContext(Mybaits_Config.class); System.out.println("测试开始"); } @Test public void mybatisConfig_Test_DataSource() throws SQLException{ DataSource ds = ctx.getBean( "dataSource",DataSource.class); String sql = "select username from vrduser where id=1"; //查看数据库vrduser中id=1的username的数据 try(Connection connection = ds.getConnection()){ Statement statement = connection.createStatement(); ResultSet rs = statement.executeQuery(sql); while (rs.next()){ System.out.println(rs.getString(1)); } } catch (Exception e) { e.printStackTrace(); } } @After public void after(){ System.out.println("测试结束"); ctx.close(); } }
测试成功并输出
测试开始
admin
测试结束