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
	}
}