JDBC——Driver、DriverManager、Statement、ResultSet

1.Driver接口

url组成
jdbc:子协议：子名称（数据库所在的主机IP）：端口号/数据库名

jdbc:mysql://localhost(127.0.0.1):3306/test

/*
	 * Dirver接口：数据库厂商必须提供的接口，从其中获取数据库的连接
	 * 1.加入mysql驱动
	 *  1）解压mysql-                      connector-java-5.1.7-bin.jar
	 *  2）在当前项目下新建lib文件夹
	 *  3）把mysql-connector-java-5.1.7-bin.jar复制到lib中
	 *  4）右键build path  add to buildpath加到类路径下
	 * */
	@Test
	public void testDriver() throws SQLException {
		//1.创建Driver 实现类的对象
		Driver driver = new com.mysql.jdbc.Driver();
		
		//2.准备连接数据库的基本信息：url,user,password
		String url = "jdbc:mysql://localhost:3306/db_person";
		Properties info = new Properties();
		info.put("user", "root");
		info.put("password", "1234");
		
		//3.调用Driver接口的connect(url, info)获取数据库连接
		Connection connection = driver.connect(url, info);
		System.out.println(connection);
	}

　　数据库与配置文件的解耦：将驱动Driver的信息放入一个配置文件中jdbc.properties中

/*
	 * 一个通用的方法，再不修改源程序的情况下，获取任何数据库的连接
	 * 解决方法：把数据库驱动Driver实现类的全类名、url、user、password
	 * 放入一个配置文件中，通过修改配置文件的方式实现和具体的数据库解耦
	 * 
	 * */
	public Connection getConnection() throws Exception {
		String driverClass = null;
		String jdbcUrl = null;
		String user = null;
		String password = null;
		
		//读取类路径下的jdbc.propertier文件
		InputStream in = getClass().getClassLoader().getResourceAsStream("jdbc.properties");
		Properties properties = new Properties();
		properties.load(in);
		driverClass = properties.getProperty("driver");//driver=com.mysql.jdbc.Driver
		jdbcUrl = properties.getProperty("jdbcUrl");//jdbcUrl=jdbc:mysql://localhost:3306/db_person
		user = properties.getProperty("user");//user=root
		password = properties.getProperty("password");//password=1234
		
		//通过反射创建Driver对象
		Driver driver = (Driver) Class.forName(driverClass).newInstance();
		Properties info = new Properties();
		info.put("user", user);
		info.put("password", password);
		
		//通过driver的connect方法获取数据库连接
		Connection connection = driver.connect(jdbcUrl, info);
		
		return connection;
		
	}
@Test
	public void tetGetConnection() throws Exception {
		System.out.println(getConnection());
	}

jdbc.properties中的内容

driver=com.mysql.jdbc.Driver
jdbcUrl=jdbc:mysql://localhost:3306/db_person
user=root
password=1234

　　

2.DriverManager类是驱动程序管理器类：管理驱动程序

/*
	 *DriverManager是驱动的管理类
	 * 1.可以通过重载的getConnection()方法获取数据库连接
	 * 2.可以同时管理多个驱动程序：若注册了多个数据库连接，
	 * 则调用getConnection()方法时传入的参数不同，即返回不同的数据库连接
	 * 
	 */
	@Test
	public void testDriverManager() throws Exception {
		//1.准备连接数据库的4个字符串
		//驱动的全类名
		String driverClass = "com.mysql.jdbc.Driver";
		//jdbc url
		String jdbcUrl = "jdbc:mysql://localhost:3306/db_person";
		//user password
		String user = "root";
		String password = "1234";
		
		//2.加载数据库驱动程序（对应的Driver实现类中有注册驱动的静态代码块）
	//	DriverManager.registerDriver(Class.forName(driverClass).newInstance());
		Class.forName(driverClass);
		
		//3.通过DriverManager 的 getConnection()方法获取数据库连接
		Connection connection = DriverManager.getConnection(jdbcUrl, user, password);
		
		System.out.println(connection);
	}

　　

3.通过Statement的CreatStatement()和executeUpdate(sql)来进行数据的插入、删除、修改

/*
	 * 通过JDBC向指定的数据表中插入、删除、修改一条记录
	 * 
	 * 1.Statement：用于执行SQL语句的对象
	 * 1）通过Connection的CreatStatement()方法来获取
	 * 2）通过executeUpdate(sql)可以执行SQL语句
	 * 3）传入的SQL可以使INSERT、UPDATE、或DELETE，但不能是SELECT
	 * 
	 * 2.Connection、Statement都是应用程序和数据库服务器的连接资源。使用后一定要关闭。
	 * 需要在finally中关闭该对象
	 * 
	 * 3.关闭的顺序：从后向前
	 * 
	 * */
	
	@Test
	public void testStatement() {

		Connection conn = null;
		Statement statement = null;
		try {
			//1.获取数据库连接
			conn = getConnection();//上面的程序中有写此方法
			
			//3.准备插入的SQL语句
			String sql = "INSERT INTO student(id, name, sex, age) "
					+ "VALUES(null, 'lili', 'woman', '20');";
			String sql1 = "DELETE FROM student WHERE id = 1";
			String sql2 = "UPDATE student SET name = 'Skye'"
					+ " WHERE id = 2";
			//4.执行插入
			//1）获取操作SQL语句的Statement对象：调用Connection的CreatStatement()方法来获取
			statement = (Statement) conn.createStatement();
			//2）调用Statement对象的executeUpdate(sql)执行SQL语句进行插入
			statement.executeUpdate(sql2);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			if(statement != null) {
				//5.关闭Statement对象
				try {
					statement.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			if(conn != null) {
				//2.关闭连接
				try {
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			
		}
	}

　　5.ResultSet：结果集，封装了使用JDBC进行查询的结果

	/**
	 * ResultSet:结果集，封装了使用JDBC进行查询的结果
	 * 1.调用Statement对象的executeQuery(sql)可以得到结果集
	 * 2.ResultSet返回的实际上就是一张数据表，有一个指针指向数据表的第一行的前面
	 * 可以调用next()方法检测下一行是否有效。若有效该方法返回true，且指针下移，相当于
	 * Iterator对象的hasNext()和next()方法的合体
	 * 3.当指针对到一行时，可以通过getXxx(index)或getXxx(columnName)获取每一列的值
	 * 例如：getInt(1)，getString("name");
	 * 4.ResultSet当然也需要关闭
	 */
	@Test
	public void testResultSet() {
		//获取id=4的student数据表的记录，并打印
		
		Connection conn = null;
		
		Statement statement = null;
		ResultSet res = null;
		
		try {
			//1.获取Connection
			conn = TestStatement.getConnection();
			//2.获取Statement
			statement = (Statement) conn.createStatement();
			//3.准备SQL
			String sql = "SELECT * FROM student";
			//4.执行查询，得到ResultSet
			res = statement.executeQuery(sql);
			//5.处理结果集
			//5.1调用next()方法检测下一行是否有效。若有效该方法返回true，且指针下移
			//5.2通过getXxx(index)或getXxx(columnName)获取每一列的值
			while(res.next()) {
				int id = res.getInt(1);
				String name = res.getString(2);
				String sex = res.getString(3);
				int age = res.getInt("age");
				
				System.out.print(id);
				System.out.print(name);
				System.out.print(sex);
				System.out.print(age);
				System.out.println();
			}
		
		} catch(Exception e){
			e.printStackTrace();
		}finally {
			//6.关闭数据库资源
			TestStatement.release(res, statement, conn);
		}
	}