public class Demo2 {
	/*
	 * 連接數(shù)據(jù)庫，得到Connection就算成功！
	 * 對數(shù)據(jù)庫做增、刪、改
	 */
	@Test
	public void fun1() throws ClassNotFoundException, SQLException {
	/*
	 * 一、得到Connection
	 * 1. 準(zhǔn)備四大參數(shù)
	 * 2. 加載驅(qū)動類
	 * 3. 得到Connection
	 */
	// 準(zhǔn)備四大參數(shù)
	String driverClassName = "com.mysql.jdbc.Driver";
	// jdbc協(xié)議的格式！jdbc:工商的名稱:子協(xié)議（由工商自己來規(guī)定）
	// 對mysql而言，它的子協(xié)議結(jié)構(gòu)：//主機(jī):端口號/數(shù)據(jù)庫名稱
	String url = "jdbc:mysql://localhost:3306/mydb3";
	String username = "root";
	String password = "123";
	
	// 加載驅(qū)動類
	Class.forName(driverClassName);
	// 使用DriverManager，以及省下的3個參數(shù)，得到Connection
	Connection con = DriverManager.getConnection(url, username, password);
	
	/*
	 * 二、對數(shù)據(jù)庫做增、刪、改
	 * 1. 通過Connection對象創(chuàng)建Statement
	 * > Statement語句的發(fā)送器，它的功能就是向數(shù)據(jù)庫發(fā)送sql語句！
	 * 2. 調(diào)用它的int executeUpdate(String sql)，它可以發(fā)送DML、DDL
	 */
	// 1. 通過Connection得到Statement對象
	Statement stmt = con.createStatement();
	// 2. 使用Statement發(fā)送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);
	}
	
	/**
	 * 執(zhí)行查詢
	 * @throws ClassNotFoundException 
	 * @throws SQLException 
	 */
	@Test
	public void fun2() throws ClassNotFoundException, SQLException {
	/*
	 * 一、得到Connection
	 * 二、得到Statement，發(fā)送select語句
	 * 三、對查詢返回的“表格”進(jìn)行解析！
	 */
	/*
	 * 一、得到連接
	 * 1. 準(zhǔn)備四大連接參數(shù)
	 */
	String driverClassName = "com.mysql.jdbc.Driver";
	String url = "jdbc:mysql://localhost:3306/exam";
	String username = "root";
	String password = "123";
	
	/*
	 * 2. 加載驅(qū)動類
	 */
	Class.forName(driverClassName);
	/*
	 * 3. 通過省下的三個參數(shù)調(diào)用DriverManger的getConnection()，得到連接
	 */
	Connection con = DriverManager.getConnection(url, username, password);
	
	/*
	 * 二、得到Statement，執(zhí)行select語句
	 * 1. 得到Statement對象：Connection的createStatement()方法
	 */
	Statement stmt = con.createStatement();
	/*
	 * 2. 調(diào)用Statement的ResultSet rs = executeQuery(String querySql)
	 */
	ResultSet rs = stmt.executeQuery("select * from emp");
	
	/*
	 * 三、解析ResultSet
	 * 1. 把行光標(biāo)移動到第一行，可以調(diào)用next()方法完成！
	 */
	while(rs.next()) {//把光標(biāo)向下移動一行，并判斷下一行是否存在！
	int empno = rs.getInt(1);//通過列編號來獲取該列的值！
	String ename = rs.getString("ename");//通過列名稱來獲取該列的值
	double sal = rs.getDouble("sal");
	
	System.out.println(empno + ", " + ename + ", " + sal);
	}
	
	/*
	 * 四、關(guān)閉資源
	 * 倒關(guān)
	 */
	rs.close();
	stmt.close();
	con.close();//這個東東，必須要關(guān)，不關(guān)就死！
	}

// 規(guī)范化
	@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);//實例化
	
	/*
	 * 二、創(chuàng)建Statement
	 */
	stmt = con.createStatement();
	String sql = "select * from emp";
	rs = stmt.executeQuery(sql);
	
	rs.last();//把光標(biāo)移動到最后一行

	rs.beforeFirst();
	
	/*
	 * 三、循環(huán)遍歷rs，打印其中數(shù)據(jù)
	 * 
	 * 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 {
	// 關(guān)閉
	if(rs != null) rs.close();
	if(stmt != null) stmt.close();
	if(con != null) con.close();
	}
	
	}
}

	/*
	 * 一、得到PreparedStatement
	 * 1. 給出sql模板：所有的參數(shù)使用?來替代
	 * 2. 調(diào)用Connection方法，得到PreparedStatement
	 */
	String sql = "select * from t_user where username=? and password=?";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	/*
	 * 二、為參數(shù)賦值
	 */
	pstmt.setString(1, username);//給第1個問號賦值，值為username
	pstmt.setString(2, password);//給第2個問號賦值，值為password
	
	ResultSet rs = pstmt.executeQuery();//調(diào)用查詢方法，向數(shù)據(jù)庫發(fā)送查詢語句
	
	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類被加載時執(zhí)行一次！
	static {
	// 給props進(jìn)行初始化，即加載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);
	}
	
	// 加載驅(qū)動類
	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實現(xiàn)類的名稱！
 * 通過類名稱，完成創(chuàng)建類對象！（反射完成的！）
 * @author cxf
 *
 */
public class DaoFactory {
	private static Properties props = null;
	static {
	// 加載配置文件內(nèi)容到props對象中
	try {
	InputStream in = DaoFactory.class
	.getClassLoader().getResourceAsStream("dao.properties");
	props = new Properties();
	props.load(in);
	} catch(Exception e) {
	throw new RuntimeException(e);
	}
	}
	/**
	 * 返回一個具體UserDao的實現(xiàn)類對象
	 * @return
	 */
	public static UserDao getUserDao() {
	/**
	 * 給出一個配置文件，文件中給出UserDao接口的實現(xiàn)類名稱！
	 * 我們這個方法，獲取實現(xiàn)類的類名，通過反射完成創(chuàng)建對象！
	 */
	/*
	 * 得到dao實現(xiàn)類的名稱
	 */
	String daoClassName = props.getProperty("cn.itcast.usermng.dao.UserDao");
	
	/*
	 * 通過反射來創(chuàng)建實現(xiàn)類的對象　
	 */
	try {
	Class clazz = Class.forName(daoClassName);
	return (UserDao)clazz.newInstance();
	} catch(Exception e) {
	throw new RuntimeException(e);
	}
	}
}

/**
 * 大數(shù)據(jù)
 * @author cxf
 *
 */
public class Demo4 {
	/**
	 * 把mp3保存到數(shù)據(jù)庫中。
	 * @throws SQLException 
	 * @throws IOException 
	 * @throws FileNotFoundException 
	 */
	@Test
	public void fun1() throws Exception {
	/*
	 * 1. 得到Connection
	 * 2. 給出sql模板，創(chuàng)建pstmt
	 * 3. 設(shè)置sql模板中的參數(shù)
	 * 4. 調(diào)用pstmt的executeUpdate()執(zhí)行
	 */
	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. 我們有的是文件，目標(biāo)是Blob
	 * 2. 先把文件變成byte[]
	 * 3. 再使用byte[]創(chuàng)建Blob
	 */
	// 把文件轉(zhuǎn)換成byte[]
	byte[] bytes = IOUtils.toByteArray(new FileInputStream("F:/流光飛舞.mp3"));
	// 使用byte[]創(chuàng)建Blob
	Blob blob = new SerialBlob(bytes);
	// 設(shè)置參數(shù)
	pstmt.setBlob(3, blob);
	
	pstmt.executeUpdate();
	}
	
	/**
	 * 從數(shù)據(jù)庫讀取mp3
	 * @throws SQLException 
	 */
	@Test
	public void fun2() throws Exception {
	/*
	 * 1. 創(chuàng)建Connection
	 */
	Connection con = JdbcUtils.getConnection();
	/*
	 * 2. 給出select語句模板，創(chuàng)建pstmt
	 */
	String sql = "select * from tab_bin";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	/*
	 * 3. pstmt執(zhí)行查詢，得到ResultSet
	 */
	ResultSet rs = pstmt.executeQuery();
	
	/*
	 * 4. 獲取rs中名為data的列數(shù)據(jù)
	 */
	if(rs.next()) {
	Blob blob = rs.getBlob("data");
	/*
	 * 把Blob變成硬盤上的文件！
	 */
	/*
	 * 1. 通過Blob得到輸入流對象
	 * 2. 自己創(chuàng)建

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[內(nèi)部有個集合，用來裝載sql語句].addBatch(sql);
	}
	stmt.executeBatch[執(zhí)行批，即一次把批中的所有sql語句發(fā)送給服務(wù)器]();

/**
 * 批處理
 * @author cxf
 *
 */
public class Demo5 {
	/**
	 * pstmt對象內(nèi)部有集合
	 * 1. 用循環(huán)瘋狂向pstmt中添加sql參數(shù)，它自己有模板，使用一組參數(shù)與模板罰沒可以匹配出一條sql語句
	 * 2. 調(diào)用它的執(zhí)行批方法，完成向數(shù)據(jù)庫發(fā)送！
	 * @throws SQLException 
	 */
	@Test
	public void fun5() throws SQLException {
	/*
	 * pstmt：
	 * > 添加參數(shù)到批中
	 * > 執(zhí)行批！
	 */
	Connection con = JdbcUtils.getConnection();
	String sql = "INSERT INTO t_stu VALUES(?,?,?,?)";
	PreparedStatement pstmt = con.prepareStatement(sql);
	
	// 瘋狂的添加參數(shù)
	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();//添加批！這一組參數(shù)就保存到集合中了。
	}
	long start = System.currentTimeMillis();
	pstmt.executeBatch();//執(zhí)行批！
	long end = System.currentTimeMillis();
	
	System.out.println(end - start);//412764, 301
	}
}