public class TestJDBC {
	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		//1、注冊(cè)驅(qū)動(dòng)
		//(1)方式一：Class.forName("驅(qū)動(dòng)類的全名稱")
		Class.forName("com.mysql.cj.jdbc.Driver");
//		(2)創(chuàng)建驅(qū)動(dòng)類的對(duì)象
//		new com.mysql.cj.jdbc.Driver();//硬編碼
		//(3)通過DriverManager注冊(cè)驅(qū)動(dòng)
//		DriverManager.registerDriver(new com.mysql.cj.jdbc.Driver());//硬編碼
		//2、獲取連接，連接數(shù)據(jù)庫
        //TCP/IP協(xié)議編程，需要服務(wù)器的IP地址和端口號(hào)
		//mysql的url格式：jdbc協(xié)議:子協(xié)議://主機(jī)名:端口號(hào)/要連接的數(shù)據(jù)庫名
		String url = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC";//其中test是數(shù)據(jù)庫名;serverTimezone是時(shí)區(qū)不設(shè)置可能報(bào)錯(cuò)
		String user = "root";
		String password = "123456";
		Connection conn = DriverManager.getConnection(url, user, password);
		//3、執(zhí)行sql
		//添加一個(gè)部門到數(shù)據(jù)庫的t_department表中
		//(1)編寫sql
		String sql = "insert into t_department values(null,'計(jì)算部2','計(jì)算鈔票2')";
		/*
		 * 回憶：	TCP/IP程序時(shí)
		 * Socket代表連接
		 * socket.getOutputStream()來發(fā)送數(shù)據(jù)，
		 * socket.getInputStream()來接收數(shù)據(jù)
		 * 
		 * 可以把Connection比喻成Socket
		 *    把Statement比喻成OutputStream
		 */
		//(2)獲取Statement對(duì)象
		Statement st = conn.createStatement();
		//(3)執(zhí)行sql
		int len = st.executeUpdate(sql);
		//(4)處理結(jié)果
		System.out.println(len>0?"成功":"失敗");
		//4、關(guān)閉
		st.close();
		conn.close();
	}
}

public class TestSelect {
	public static void main(String[] args) throws Exception{
		// 1、注冊(cè)驅(qū)動(dòng)
		Class.forName("com.mysql.cj.jdbc.Driver");
		// 2、連接數(shù)據(jù)庫
		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?serverTimezone=UTC", "root", "123456");
		// 3、執(zhí)行sql
		String sql = "SELECT * FROM t_department";
		Statement st = conn.createStatement();
		ResultSet rs = st.executeQuery(sql);//ResultSet看成InputStream
		while(rs.next()){//next()表示是否還有下一行
			Object did = rs.getObject(1);//獲取第n列的值
			Object dname = rs.getObject(2);
			Object desc = rs.getObject(3);
			/*
			int did = rs.getInt("did");//也可以根據(jù)列名稱，并且可以按照數(shù)據(jù)類型獲取
			String dname = rs.getString("dname");
			String desc = rs.getString("description");
			 */
			System.out.println(did +"\t" + dname + "\t"+ desc);
		}
		// 4、關(guān)閉
		rs.close();
		st.close();
		conn.close();
	}
}

	String sql = "insert into t_employee(ename,tel,gender,salary) values('" + ename + "','" + tel + "','" + gender + "'," + salary +")";
		Statement st = conn.createStatement();
		int len = st.executeUpdate(sql);

	String sql = "SELECT * FROM t_employee where ename='" + ename + "'";
		//如果我此時(shí)從鍵盤輸入ename值的時(shí)候，輸入：張三' or '1'= '1
		//結(jié)果會(huì)把所有數(shù)據(jù)都查詢出來
		Statement st = conn.createStatement();
		ResultSet rs = st.executeQuery(sql);

String sql = "insert into user(username,photo) values('chailinyan', 圖片字節(jié)流)";
//此時(shí)photo是blob類型的數(shù)據(jù)時(shí)，無法在sql中直接拼接

		String sql = "insert into t_employee(ename,tel,gender,salary) values(?,?,?,?)";
		PreparedStatement pst = conn.prepareStatement(sql);//這里要傳帶？的sql，然后mysql端就會(huì)對(duì)這個(gè)sql進(jìn)行預(yù)編譯
		//根據(jù)字段來設(shè)置？的具體值
		/*pst.setString(1, ename);
		pst.setString(2, tel);
		pst.setString(3, gender);
		pst.setDouble(4, salary);*/
		pst.setObject(1, ename);
		pst.setObject(2, tel);
		pst.setObject(3, gender);
		pst.setObject(4, salary);
		int len = pst.executeUpdate();//此處不能傳sql
		System.out.println(len);

String sql = "SELECT * FROM t_employee where ename=?";
		//即使輸入'張三' or '1'= '1'也沒問題
		PreparedStatement pst = conn.prepareStatement(sql);
		//中間加入設(shè)置？的值
		pst.setObject(1, ename);
		ResultSet rs = pst.executeQuery();

		String sql = "insert into user(username,photo) values(?,?)";
		PreparedStatement pst = conn.prepareStatement(sql);
		//設(shè)置？的值
		pst.setObject(1, "xiaoyu");
		FileInputStream fis = new FileInputStream("D:/QMDownload/img/15.jpg");
		pst.setBlob(2, fis);
		int len = pst.executeUpdate();
		System.out.println(len>0?"成功":"失敗");