webday17JDBC入门,DAO模式mySQL时间类型转换,批处理_MySQL

public class Demo2 {
	/*
	 * 连接数据库，得到Connection就算成功！
	 * 对数据库做增、删、改
	 */
	@Test
	public void fun1() throws ClassNotFoundException, SQLException {
	/*
	 * 一、得到Connection
	 * 1. 准备四大参数
	 * 2. 加载驱动类
	 * 3. 得到Connection
	 */
	// 准备四大参数
	String driverClassName = "com.mysql.jdbc.Driver";
	// jdbc协议的格式！jdbc:工商的名称:子协议（由工商自己来规定）
	// 对mysql而言，它的子协议结构：//主机:端口号/数据库名称
	String url = "jdbc:mysql://localhost:3306/mydb3";
	String username = "root";
	String password = "123";
	
	// 加载驱动类
	Class.forName(driverClassName);
	// 使用DriverManager，以及省下的3个参数，得到Connection
	Connection con = DriverManager.getConnection(url, username, password);
	
	/*
	 * 二、对数据库做增、删、改
	 * 1. 通过Connection对象创建Statement
	 * > Statement语句的发送器，它的功能就是向数据库发送sql语句！
	 * 2. 调用它的int executeUpdate(String sql)，它可以发送DML、DDL
	 */
	// 1. 通过Connection得到Statement对象
	Statement stmt = con.createStatement();
	// 2. 使用Statement发送sql语句！
//	String sql = "INSERT INTO stu VALUES('ITCAST_0003', 'wangWu', 88, 'male')";
//	String sql = "UPDATE stu SET name='zhaoLiu', age=22, " +
//	"gender='female' WHERE number='ITCAST_0003'";
	String sql = "DELETE FROM stu";
	int r = stmt.executeUpdate(sql);
	System.out.println(r);
	}
	
	/**
	 * 执行查询
	 * @throws ClassNotFoundException 
	 * @throws SQLException 
	 */
	@Test
	public void fun2() throws ClassNotFoundException, SQLException {
	/*
	 * 一、得到Connection
	 * 二、得到Statement，发送select语句
	 * 三、对查询返回的“表格”进行解析！
	 */
	/*
	 * 一、得到连接
	 * 1. 准备四大连接参数
	 */
	String driverClassName = "com.mysql.jdbc.Driver";
	String url = "jdbc:mysql://localhost:3306/exam";
	String username = "root";
	String password = "123";
	
	/*
	 * 2. 加载驱动类
	 */
	Class.forName(driverClassName);
	/*
	 * 3. 通过省下的三个参数调用DriverManger的getConnection()，得到连接
	 */
	Connection con = DriverManager.getConnection(url, username, password);
	
	/*
	 * 二、得到Statement，执行select语句
	 * 1. 得到Statement对象：Connection的createStatement()方法
	 */
	Statement stmt = con.createStatement();
	/*
	 * 2. 调用Statement的ResultSet rs = executeQuery(String querySql)
	 */
	ResultSet rs = stmt.executeQuery("select * from emp");
	
	/*
	 * 三、解析ResultSet
	 * 1. 把行光标移动到第一行，可以调用next()方法完成！
	 */
	while(rs.next()) {//把光标向下移动一行，并判断下一行是否存在！
	int empno = rs.getInt(1);//通过列编号来获取该列的值！
	String ename = rs.getString("ename");//通过列名称来获取该列的值
	double sal = rs.getDouble("sal");
	
	System.out.println(empno + ", " + ename + ", " + sal);
	}
	
	/*
	 * 四、关闭资源
	 * 倒关
	 */
	rs.close();
	stmt.close();
	con.close();//这个东东，必须要关，不关就死！
	}

// 规范化
	@Test
	public void fun3() throws Exception {
	Connection con = null;//定义引用
	Statement stmt = null;
	ResultSet rs = null;
	try {
	/*
	 * 一、得到连接
	 */
	String driverClassName = "com.mysql.jdbc.Driver";
	String url = "jdbc:mysql://localhost:3306/exam";
	String username = "root";
	String password = "123";
	
	Class.forName(driverClassName);
	con = DriverManager.getConnection(url, username, password);//实例化
	
	/*
	 * 二、创建Statement
	 */
	stmt = con.createStatement();
	String sql = "select * from emp";
	rs = stmt.executeQuery(sql);
	
	rs.last();//把光标移动到最后一行

	rs.beforeFirst();
	
	/*
	 * 三、循环遍历rs，打印其中数据
	 * 
	 * getString()和getObject()是通用的！
	 */
//	while(rs.next()) {
//	System.out.println(rs.getObject(1) + ", " 
//	+ rs.getString("ename") + ", " + rs.getDouble("sal"));
//	}
	
	int count = rs.getMetaData().getColumnCount();
	while(rs.next()) {//遍历行
	for(int i = 1; i <= count; i++) {//遍历列
	System.out.print(rs.getString(i));
	if(i < count) {
	System.out.print(", ");
	}
	}
	System.out.println();
	}
	
	} catch(Exception e) {
	throw new RuntimeException(e);
	} finally {
	// 关闭
	if(rs != null) rs.close();
	if(stmt != null) stmt.close();
	if(con != null) con.close();
	}
	
	}
}

	/*
	 * 一、得到PreparedStatement
	 * 1. 给出sql模板：所有的参数使用?来替代
	 * 2. 调用Connection方法，得到PreparedStatement
	 */
	String sql = "select * from t_user where username=? and password=?";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	/*
	 * 二、为参数赋值
	 */
	pstmt.setString(1, username);//给第1个问号赋值，值为username
	pstmt.setString(2, password);//给第2个问号赋值，值为password
	
	ResultSet rs = pstmt.executeQuery();//调用查询方法，向数据库发送查询语句
	
	pstmt.setString(1, "liSi");
	pstmt.setString(2, "123");
	
	pstmt.executeQuery();

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=UTF8
username=root
password=123

public class JdbcUtils {
	private static Properties props = null;
	
	// 只在JdbcUtils类被加载时执行一次！
	static {
	// 给props进行初始化，即加载dbconfig.properties文件到props对象中
	try {
	InputStream in = JdbcUtils.class.getClassLoader()
	.getResourceAsStream("dbconfig.properties");//配置文件路径在src目录下

	props = new Properties();
	props.load(in);
	} catch(IOException e) {
	throw new RuntimeException(e);
	}
	
	// 加载驱动类
	try {
	Class.forName(props.getProperty("driverClassName"));
	} catch (ClassNotFoundException e) {
	throw new RuntimeException(e);
	}
	}
	
	// 获取连接!
	public static Connection getConnection() throws SQLException {
	// 得到Connection
	return DriverManager.getConnection(props.getProperty("url"),
	props.getProperty("username"), 
	props.getProperty("password"));
	}
}

/**
 * 通过配置文件得到dao实现类的名称！
 * 通过类名称，完成创建类对象！（反射完成的！）
 * @author cxf
 *
 */
public class DaoFactory {
	private static Properties props = null;
	static {
	// 加载配置文件内容到props对象中
	try {
	InputStream in = DaoFactory.class
	.getClassLoader().getResourceAsStream("dao.properties");
	props = new Properties();
	props.load(in);
	} catch(Exception e) {
	throw new RuntimeException(e);
	}
	}
	/**
	 * 返回一个具体UserDao的实现类对象
	 * @return
	 */
	public static UserDao getUserDao() {
	/**
	 * 给出一个配置文件，文件中给出UserDao接口的实现类名称！
	 * 我们这个方法，获取实现类的类名，通过反射完成创建对象！
	 */
	/*
	 * 得到dao实现类的名称
	 */
	String daoClassName = props.getProperty("cn.itcast.usermng.dao.UserDao");
	
	/*
	 * 通过反射来创建实现类的对象　
	 */
	try {
	Class clazz = Class.forName(daoClassName);
	return (UserDao)clazz.newInstance();
	} catch(Exception e) {
	throw new RuntimeException(e);
	}
	}
}

/**
 * 大数据
 * @author cxf
 *
 */
public class Demo4 {
	/**
	 * 把mp3保存到数据库中。
	 * @throws SQLException 
	 * @throws IOException 
	 * @throws FileNotFoundException 
	 */
	@Test
	public void fun1() throws Exception {
	/*
	 * 1. 得到Connection
	 * 2. 给出sql模板，创建pstmt
	 * 3. 设置sql模板中的参数
	 * 4. 调用pstmt的executeUpdate()执行
	 */
	Connection con = JdbcUtils.getConnection();
	String sql = "insert into tab_bin values(?,?,?)";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	pstmt.setInt(1, 1);
	pstmt.setString(2, "流光飞舞.mp3");
	/**
	 * 需要得到Blob
	 * 1. 我们有的是文件，目标是Blob
	 * 2. 先把文件变成byte[]
	 * 3. 再使用byte[]创建Blob
	 */
	// 把文件转换成byte[]
	byte[] bytes = IOUtils.toByteArray(new FileInputStream("F:/流光飞舞.mp3"));
	// 使用byte[]创建Blob
	Blob blob = new SerialBlob(bytes);
	// 设置参数
	pstmt.setBlob(3, blob);
	
	pstmt.executeUpdate();
	}
	
	/**
	 * 从数据库读取mp3
	 * @throws SQLException 
	 */
	@Test
	public void fun2() throws Exception {
	/*
	 * 1. 创建Connection
	 */
	Connection con = JdbcUtils.getConnection();
	/*
	 * 2. 给出select语句模板，创建pstmt
	 */
	String sql = "select * from tab_bin";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	/*
	 * 3. pstmt执行查询，得到ResultSet
	 */
	ResultSet rs = pstmt.executeQuery();
	
	/*
	 * 4. 获取rs中名为data的列数据
	 */
	if(rs.next()) {
	Blob blob = rs.getBlob("data");
	/*
	 * 把Blob变成硬盘上的文件！
	 */
	/*
	 * 1. 通过Blob得到输入流对象
	 * 2. 自己创建

for(int i = 0; i < 10; i++) {
	String number = "S_10" + i;
	String name = "stu" + i;
	int age = 20 + i;
	String gender = i % 2 == 0 ? "male" : "female";
	String sql = "insert into stu values('" + number + "', '" + name + "', " + age + ", '" + gender + "')";
	stmt[内部有个集合，用来装载sql语句].addBatch(sql);
	}
	stmt.executeBatch[执行批，即一次把批中的所有sql语句发送给服务器]();

/**
 * 批处理
 * @author cxf
 *
 */
public class Demo5 {
	/**
	 * pstmt对象内部有集合
	 * 1. 用循环疯狂向pstmt中添加sql参数，它自己有模板，使用一组参数与模板罚没可以匹配出一条sql语句
	 * 2. 调用它的执行批方法，完成向数据库发送！
	 * @throws SQLException 
	 */
	@Test
	public void fun5() throws SQLException {
	/*
	 * pstmt：
	 * > 添加参数到批中
	 * > 执行批！
	 */
	Connection con = JdbcUtils.getConnection();
	String sql = "INSERT INTO t_stu VALUES(?,?,?,?)";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	// 疯狂的添加参数
	for(int i = 0; i < 10000; i++) {
	pstmt.setInt(1, i+1);
	pstmt.setString(2, "stu_" + i);
	pstmt.setInt(3, i);
	pstmt.setString(4, i%2==0?"男":"女");
	
	pstmt.addBatch();//添加批！这一组参数就保存到集合中了。
	}
	long start = System.currentTimeMillis();
	pstmt.executeBatch();//执行批！
	long end = System.currentTimeMillis();
	
	System.out.println(end - start);//412764, 301
	}
}