maven下mysql数据库连接池

2024-07-11 06:08| 来源: 网络整理| 查看: 265

一、目录结构

创建java、resource并标记为源文件和资源文件如下：在这里插入图片描述创建完成如下：

在这里插入图片描述二、创建配置文件（文件名：MyJDBC.properties) 创建名为MyJDBC.propertie放在资源文件resource文件夹下（没有就新建，并标记为资源文件），不然后面用的时候找不到

driverClassName=com.mysql.cj.jdbc.Driver url=jdbc:mysql://localhost:3306/Test?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC username=root password=123456 #初始连接数 initialSize=5 maxActive=10 maxWait=3000

注意：driverClassName=com.mysql.cj.jdbc.Driver 这里是mysql 8.0或8.0以上的写法，8.0以下的不要cj url里面的Test是mysql的库名

三、在工具类Ultile里面创建数据库连接池的工具

在里面创建类Mysqlcoll

package com.yang.Ultile; import com.alibaba.druid.pool.DruidDataSourceFactory; import com.yang.entity.User; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.jdbc.core.JdbcTemplate; import javax.sql.DataSource; import java.io.IOException; import java.io.InputStream; import java.util.List; import java.util.Properties; public class MysqlColl { private static DataSource dataSource = null; static { try { Properties properties = new Properties(); InputStream ins = MysqlColl.class.getClassLoader().getResourceAsStream ("MyJDBC.properties"); properties.load(ins); dataSource = DruidDataSourceFactory.createDataSource(properties); } catch (IOException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } public JdbcTemplate getTmp(){ return new JdbcTemplate(dataSource); } }

注意：这里使用maven框架没有包的，在pom.xml里面导入

mysql mysql-connector-java 8.0.11 org.springframework spring-beans 5.0.0.RELEASE com.alibaba druid 1.0.9 org.springframework spring-jdbc 5.2.9.RELEASE org.junit.jupiter junit-jupiter RELEASE compile

四、测试

进入mysql、创建Test库、然后在创建demo01的表来提供测试

# 建库 create database Test; # 建表 create table demo01( id int primary key , username varchar(15) not null , password varchar(15) not null , gender varchar(2) not null , age int not null ); # 插入数据 insert into demo01 (username, password, gender, age) VALUES ('xx','Ytg','男',18), ('xy','ytg123','女',17), ('yy','kj','男',15);

在entity里面创建User的实体类类

package com.yang.entity; public class User { private String username,gender,password; private Integer age,id; public User(){} public User(int id,String username, String gender, String password, Integer age) { this.username = username; this.gender = gender; this.password = password; this.age = age; this.id = id; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getGender() { return gender; } public void setGender(String gender) { this.gender = gender; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } @Override public String toString() { return "User{" + "username='" + username + '\'' + ", gender='" + gender + '\'' + ", password='" + password + '\'' + ", age=" + age + '}'; } }

在com.yang包下创建Test的包来装测试类test 在这里插入图片描述 test.class代码如下：

package Test; import com.yang.Ultile.MysqlColl; import com.yang.entity.User; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.jdbc.core.JdbcTemplate; import java.util.List; public class test { public static void main(String[] args) { String sql = "select * from demo01"; JdbcTemplate tmp = new MysqlColl().getTmp(); List userList = tmp.query(sql, new BeanPropertyRowMapper(User.class)); for (User u : userList){ System.out.println(u); } } }

运行test如下：在这里插入图片描述

【本文地址】

公司简介

联系我们