MySQL 从入门到入魔之数据库连接池 (04)

db.driver=com.mysql.cj.jdbc.Driverdb.url=jdbc:mysql://localhost:3306/newdb3?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=truedb.username=rootdb.password=123456db.maxActive=10db.initialSize=2

  //创建读取配置文件的属性对象  Properties p = new Properties();  //得到文件输入流 这种写法会自动去src/main/resources目录下找文件  InputStream ips = Demo03.class.getClassLoader()      .getResourceAsStream("my.properties");  //把文件输入流交给属性对象  p.load(ips);  //读取数据  String name = p.getProperty("name");  //getProperty方法只能读取字符串  String age = p.getProperty("age");  System.out.println(name+":"+age);

public class DBUtils {  private static DruidDataSource ds;  //因为读取配置文件只需要读取一次,连接池对象也只需要创建一次   static {    //读取配置文件里面的数据    Properties p = new Properties();    InputStream ips = DBUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");    try {      p.load(ips);    } catch (IOException e) {
      e.printStackTrace();    }    String driver = p.getProperty("db.driver");    String url = p.getProperty("db.url");    String username = p.getProperty("db.username");    String password = p.getProperty("db.password");    String maxActive = p.getProperty("db.maxActive");    String initialSize = p.getProperty("db.initialSize");    ds = new DruidDataSource();    ds.setDriverClassName(driver);    ds.setUrl(url);    ds.setUsername(username);    ds.setPassword(password);    // 设置初始连接数量    ds.setInitialSize(Integer.parseInt(initialSize));    // 设置最大连接数量    ds.setMaxActive(Integer.parseInt(maxActive));  }  public static Connection getConn() throws SQLException {    // 注册驱动    // 从连接池对象中获取连接 异常抛出    Connection conn = ds.getConnection();    System.out.println(conn);    return conn;  }}

import java.sql.Connection;import java.sql.Statement;import java.util.Scanner;/** * 注册功能 * @author 海拥😋 * @date 2021年12月23日 下午2:04:42 */public class Demo04 {  public static void main(String[] args) {    Scanner sc = new Scanner(System.in);    System.out.println("请输入用户名");    String username = sc.nextLine();    System.out.println("请输入密码");    String password = sc.nextLine();    sc.close();    // 获取连接    try (Connection conn = DBUtils.getConn();) {      Statement s = conn.createStatement();      String sql = "insert into user values(null,'"+username+"','"+password+"')";      s.executeUpdate(sql);      System.out.println("注册成功");    } catch (Exception e) {      e.printStackTrace();    }  }}

import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.Statement;import java.util.Scanner;/**  * 登录功能 * @author 海拥😋 * @date 2021年12月23日 下午2:11:29 */public class Demo05 {  public static void main(String[] args) {    Scanner sc = new Scanner(System.in);    System.out.println("请输入用户名");    String username = sc.nextLine();    System.out.println("请输入密码");    String password = sc.nextLine();        //获取连接    try (Connection conn = DBUtils.getConn();) {      Statement s = conn.createStatement();//      String sql =//          "select count(*) from user where username='"//          +username+"'and password='"+password+"'";//      ResultSet rs = s.executeQuery(sql);            //通过PrepredStatement解决SQL注入问题      String sql = "select count(*) from user where username=? and password=?";      //在编译时已经将SQL语句的业务逻辑锁死 用户写的内容不会再影响逻辑      PreparedStatement ps = conn.prepareStatement(sql);      //替换sql中的?      ps.setString(1, username);      ps.setString(2, password);      //执行SQL      ResultSet rs = ps.executeQuery();      //查询回来的是符合条件的数量 只有一条数据所以可以用if 如果查询回来的是      //多条数据必须用while      if(rs.next()) {        //取出查询回来的符合条件的数量        int count =rs.getInt(1);        if(count>0) {          System.out.println("登录成功");        }else {          System.out.println("登录失败");        }      }    } catch (Exception e) {      e.printStackTrace();    }  }}

import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.Statement;/** * 批量操作 * @author 海拥😋 * @date 2021年12月23日 下午3:27:24 */public class Demo06 {  public static void main(String[] args) {    //获取连接    try (Connection conn = DBUtils.getConn();) {      String sql1="insert into user values(null,'刘备','123')";      String sql2="insert into user values(null,'关羽','123')";      String sql3="insert into user values(null,'张飞','123')";      Statement s = conn.createStatement();//      s.executeUpdate(sql1);//      s.executeUpdate(sql2);//      s.executeUpdate(sql3);      //通过批量操作将多次数据传输合并成一次//      s.addBatch(sql1);//      s.addBatch(sql2);//      s.addBatch(sql3);//      //执行批量操作//      s.executeBatch();//      System.out.println("执行完成");      //preparedStatement批量操作      String sql = "insert into user values(null,?,?)";      PreparedStatement ps = conn.prepareStatement(sql);      for (int i = 0;i<100;i++) {        ps.setString(1, "name"+i);        ps.setString(2, "pw"+i);        //添加到批量操作        ps.addBatch();        //每隔20次执行一次 避免内存溢出        if(i%20==0) {          ps.executeBatch();        }        }      //执行批量操作      ps.executeBatch();      System.out.println("执行完成");    } catch (Exception e) {      e.printStackTrace();    }  }}

import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.util.Scanner;/**  * 分页查询 * @author 海拥😋 * @date 2021年12月23日 下午4:22:49 */public class Demo07 {  public static void main(String[] args) {    Scanner sc = new Scanner(System.in);    System.out.println("请输入查询的页数");    int page = sc.nextInt() ;    System.out.println("请输入查询的条数");    int count = sc.nextInt();    if(page<1) {      System.out.println("输入错误");    }    //获取连接    try (Connection conn = DBUtils.getConn();) {      String sql ="select username,password from user limit ?,?";      PreparedStatement ps =conn.prepareStatement(sql);      //第一个？代表跳过的条数=（请求页数-1）*条数      ps.setInt(1, (page-1)*count);      //第二个?代表请求条数(每页条数)      ps.setInt(2,count);      //执行查询      ResultSet rs = ps.executeQuery();      while(rs .next()) {      String username = rs.getString(1);      String password = rs.getString(2);      System.out.println( username+":"+password) ;      }    } catch (Exception e) {      e.printStackTrace();    }  }}

import java.sql.Connection;import java.sql.ResultSet;import java.sql.Statement;/** * 获取自增主键值 * @author 海拥😋 * @date 2021年12月23日 下午4:40:33 */public class Demo08 {  public static void main(String[] args) {    //获取连接    try (Connection conn = DBUtils.getConn();) {      String sql =          "insert into user values(null,'james','123456')";      Statement s = conn.createStatement();      //编译SQL语句时,需要设置返回自增主键值      s.executeUpdate(sql,Statement.RETURN_GENERATED_KEYS);      //通过结果集 获取自增的主键值      ResultSet rs  = s.getGeneratedKeys();      if(rs.next()) {        int id =rs.getInt(1);        System.out.println("id="+id);      }      System.out.println("插入完成");    } catch (Exception e) {      e.printStackTrace();    }  }}

import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.Statement;import java.util.Scanner;/** * @author 海拥😋 * @date 2021年12月23日 下午5:17:59 */public class Demo09 {  public static void main(String[] args) {    Scanner sc = new Scanner(System.in);    System.out.println("请输入球队名字");    String teamName = sc.nextLine();    System.out.println("请输入球员名字");    String playerName = sc.nextLine();    // 获取连接    try (Connection conn = DBUtils.getConn();) {      String sql = "insert into team values(null,?)";      PreparedStatement ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);      // 替换?      ps.setString(1, teamName);      // 执行      ps.executeUpdate();      // 获取自增主键值      ResultSet rs = ps.getGeneratedKeys();      if (rs.next()) {        int teamId = rs.getInt(1);        System.out.println("球队id:"+teamId);        String psql = "insert into player values(null,?,?)";        PreparedStatement pps = conn.prepareStatement(psql);        pps.setString(1, playerName);        pps.setInt(2, teamId);        pps.executeUpdate();        System.out.println("保存完成!");      }    } catch (Exception e) {      e.printStackTrace();    }  }}