import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.testng.annotations.Test;import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.*;
import java.util.ArrayList;
import java.util.Properties;
//大概的流程就是:1. 注册驱动 2.设置连接路径 3.用户名密码 4.设置conneion连接对象 5.设置sql语句 6.创建执行sql语句对象(preparedstatement) 7.执行并且处理返回值 8.释放public class trainDemo1 {
//    @Test//写路径单个连接     (对数据库操作)public void test1()throws Exception{Class.forName("com.mysql.jdbc.Driver");//注册驱动 这个类是驱动类String url = "jdbc:mysql://127.0.0.1:3306/test?useSSL=false&useServePrepStmts=true";//这个是连接路径 SSL是加密 后面的是预编译String name = "root";String password = "123";Connection conn = DriverManager.getConnection(url,name,password);String sql = "create database if not exists lp";PreparedStatement execute = conn.prepareStatement(sql);int count = execute.executeUpdate();execute.close();conn.close();}//    @Test//省略写路径单个连接          (对数据表操作)public void test2()throws Exception{String url = "jdbc:mysql:///lp?useSSL=false&useServePrepStmts=true";String name = "root";String passwd = "123";Connection conn = DriverManager.getConnection(url,name,passwd);String sql = "create table if not exists stu(" +"id INT primary key ," +"name char(5)," +"age INT )";PreparedStatement execute = conn.prepareStatement(sql);int count = execute.executeUpdate();execute.close();conn.close();}//    @Test//插入数据public void test3() throws Exception{String url = "jdbc:mysql:///lp?useSSL=false&useServePrepStmts=true";String name = "root";String passwd = "123";Connection conn = DriverManager.getConnection(url,name,passwd);//这里的是接收前端给的数据   尽量用包装类来定义类型,这里只做演示int id = 1;String names = "pop";int age = 2;String sql = "insert into stu values(?,?,?)";PreparedStatement execute = conn.prepareStatement(sql);//其实是有直接的createstatment的 但是为了防止SQL注入问题出现,就是用这个类型//设置?初始值 , 这样设置后就会在底层转义, 就不会导致SQL注入问题出现execute.setInt(1,id);execute.setString(2,names);execute.setInt(3,age);int cout = execute.executeUpdate();System.out.println(cout>0);execute.close();conn.close();}@Test//获取数据 返回的是DefaultSet类型//这里换一种形式来建立连接, 用数据库连接池来连接  这里就需要jar包 和 配置文件public void test4()throws Exception{//1.导入jar包//2.写配置文件//3.加载配置文件(我们用对象来加载)Properties prop = new Properties();prop.load(new FileInputStream("G:\\javapack\\train\\mytrain\\src\\init.ini"));//4.创建数据库连接池对象(记得:德鲁伊数据库工厂)DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);//5.获取连接对象Connection conn = dataSource.getConnection();//连接成功 (如果没成功,大部分可能是配置文件写的有问题)String sql = "select *from stu";PreparedStatement execute = conn.prepareStatement(sql);ResultSet rs = execute.executeQuery();//这里要注意 在没有使用rs.next()时 , 其实是有一个游标指向的是数据的字段名那行//用了next()方法,游标才会向下移动一行,并且自动判断是否为有效行,如果是就可以获取数据,如果不是就无法获取//当然 如果数据比较多我们也可以定义一个对象来封装,用集合来储存ArrayList<pojo> array = new ArrayList<>();while (rs.next()){int id = rs.getInt(1); //也可以写字段名  这里就是根据数据表来按照类型获取数据String name = rs.getString("name"); //有点像python中的loc和ilocint age = rs.getInt("age");pojo sign = new pojo(id,name,age);array.add(sign);}//然后通过集合来打印数据 都是可以的//最后要记得释放空间(范围小的先释放)rs.close();execute.close();conn.close();}
}