day22 Java语言中的------JDBC连接

day22 Java语言中的------JDBC连接

一、JDBC概述：

“JDBC”就是Java连接数据库，根据数据库的不同建立的连接也有一定的区别。我们主要还是对MySQL数据库进行数据的操作。JDBC架构中主要包含两种：一种是JDBC应用程序层，一种是JDBC驱动程序层。下表是JDBC与各种数据库连接的图示。下面就具体的来了解一下Java与数据库之间的一个关系。

二、JDBC:

在具体开始学习JDBC之前，做好相应的准备工作。在MySQL数据库官网下载好相应的jar包（mysql-connector-java-5.1.24-bin.jar），在MySQL数据库中建立好test数据库，以及一张emp数据表，对数据表做好相应的数据准备。

1、使用JDBC连接数据库的基本步骤：

在Java语言中，我们队数据库的连接使用jdbc技术，一般分为以下几个步骤。

1.1、加载驱动：使用Class.forName("......");

1.2、建立连接：使用DriverManager.getConnection("......");

1.3、创建SQL语句对象。createStatement（）

1.4、通过SQL对象调取相应的sql语句执行的方法

具体实例：

//使用JDBC连接数据库
package www.com.c1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JDBC01 {

	/*
	* 1、com.mysql.jdbc.Driver。加载驱动，这个是固定语法，根据不同的数据库可以更改。
	* 2、jdbc:mysql://。类似于协议
	* 3、localhost:3306/。安装数据库的本地主机和端口号。也可以改为IP地址和端口号
	* 4、test。数据库名
	* 5、?，&。表示所带的参数，和参数之间的连接。
	* 6、user。数据库的用户名是什么？
	* 7、password。数据库的密码是什么？
	*/
	//连接方式一
	private static final String URL01 = 
			"jdbc:mysql://localhost:3306/test?user=root&password=123456";

	    //连接方式二
	    /*private static final String URL02 ="jdbc:mysql://localhost:3306/test";
	        private static String user ="root";
	        private static String password = "123456";
	    */
	//创建连接的对象
	private static Connection connection;

public static void main(String[] args) {
		try {
		//1、加载驱动
		Class.forName("com.mysql.jdbc.Driver");

		//2、建立连接，方式一。并创建连接对象。
		connection = DriverManager.getConnection(URL01);

			/*	//建立连接，方式二。
				DriverManager.getConnection(URL02, user, password);
			*/
		//3、创建SQL语句对象。
		Statement statement = connection.createStatement();

//一、执行查询语句。
		//(1)、只能执行查询的sql语句,并使用resultSet结果集来接收存储查询到的所有结果
		ResultSet resultSet = statement.executeQuery("select * from emp");
		//(2)、遍历结果集
		while (resultSet.next()) {
			//输出结果集
			System.out.println(
					"id："+resultSet.getInt("id")+";"+
					"用户名："+resultSet.getString("username")+";"+
					"密码："+resultSet.getString("password"));
			}
//二、执行更新语句。
		//（1）更新数据。注意使用更新操作的时候返回值是int类型，即某行数据是否受影响
		int updateCount = statement.executeUpdate(
		"update emp set password=888888 where id=2");

		//（2）判断是否更新成功。
		        if (updateCount>0) {
				System.out.println("更新成功！");
			} else {
				System.out.println("更新失败！");
			}

//三、执行任意的sql语句。
	//返回值：注意返回类型是布尔类型，主要分为两种。
	          //一般在创建表或创建数据库的时候最适用。
	    //返回true时：执行的是select语句
	   //返回false时：执行的是插入、更新、删除、或者是create语句
    //if not exists关键字是判断该表是否存在，如果存在就不创建
	    boolean create = statement.execute(
		"create table if not exists test(id int primary key,name varchar(20))");

		if (create = true) {
		    System.out.println("创建成功！");
		} else {
			System.out.println("创建失败！");
		}
	} catch (ClassNotFoundException e) {
		e.printStackTrace();
	} catch (SQLException e) {
		e.printStackTrace();
	}
    }
}

2、通过JDBC连接技术，实现“动态sql”操作数据表。

具体实例：

//JDBC中的使用动态sql查询数据
package www.com.c1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JDBC02 {
		//定义连接数据库字符
		private static final String URL = 
			        "jdbc:mysql://localhost:3306/test";
		//定义字符接收连接数据
		private static Connection connection;

public static void main(String[] args) {
		try {

		//1、加载驱动
		Class.forName("com.mysql.jdbc.Driver");

		//2、建立连接
		connection = DriverManager.getConnection(URL, "root", "123456");

		//3、编译动态sql
		PreparedStatement ps = connection.prepareStatement(
				"select * from emp where id=? and username=?");

		//4、假设用户从页面上传递id和username两个参数，
		    //并作为查询条件查询数据。★★★★
			int id = 2;
			String username = "ls";

		//5、将用户传递过来的id和username复制到动态sql的？处，作为条件
			ps.setInt(1, id);
			ps.setString(2, username);
		//注意：在这一步复制的时候，1代表第一个问号，2代表第二个问号，
			//问号是从小标1开始的，不是0.

		//6、使用ps调用executeQuery()方法,
					//并将查询到的结果集接收,ResultSet表示结果集
			ResultSet resultSet = ps.executeQuery();

		//7、输出查询到的结果
			while (resultSet.next()) {
			    System.out.println("ID为："+resultSet.getInt("id"));
			    System.out.println("用户名为："+
			        resultSet.getString("username"));
			}
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e){ 
			e.printStackTrace();
		}
	}
}

3、使用属性文件和封装sql执行方法来操作数据表。

属性文件：就是将一些不改变的代码写入一个文件中，通过调取这个文件直接就可以实现连接。同时在更改数据库信息的时候就只需要更改属性文件即可。不需要更改指定的代码。

具体实例：

（1）、建立属性文件。

在项目的“SRC”一级目录下新建一个文件。new-->Other-->输入Text file就可以创建了。将相关的属性写入到这个文件中

    #连接jdbc的属性文件

    driver = com.mysql.jdbc.Driver
    URL = jdbc:mysql://localhost:3306/test
    username = root
    password = 123456

命名为：jdbc.properties文件。

（2）、创建JdbcMethod类。用来封装相应的方法。并连接对应的属性文件。

package www.com.c2;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ResourceBundle;

//主要用于封装使用动态sql的所有方法。以及数据库的属性文件连接
	//注意：我们再属性文件jdbc.properties中已经将各种属性写好了，我们只需要应用。

public class JdbcMethod {

//1、使用构造函数建立数据库连接：
//   在jdbctest类中是创建该类的对象，
//   我们可以直接通过构造函数来建立连接，因为构造函数是在创建对象的时刻就执行代码。

		//  3)定义conn接收连接数据
				private Connection connection;

	public JdbcMethod(){
		//  1)加载属性文件
		ResourceBundle bundle = ResourceBundle.getBundle("jdbc");
			String driver = bundle.getString("driver");
			String url = bundle.getString("URL");
			String user = bundle.getString("username");
			String password = bundle.getString("password");

			try {

		//	2)加载驱动
				Class.forName(driver);

		//	4)建立连接
			  connection = DriverManager.getConnection(url, user, password);

			} catch (ClassNotFoundException e) {
				e.printStackTrace();
			} catch (SQLException e) {
				e.printStackTrace();
			}
	}
//---------------------------------------------------

//2、写动态sql

	// 1)、封装实现insert、update、delete操作
		public int excuteUpdate(String sql){

			Statement statement;
			int count = 0;
			try {
				//(1):创建sql对象
				statement = connection.createStatement();
				//(2):执行更新语句
				count = statement.executeUpdate(sql);
			} catch (SQLException e) {
				e.printStackTrace();
			}
			return count;
		}
	// 2)、封装实现查询语句
		public ResultSet excuteQuery(String sql){
			Statement statement;
			ResultSet rs = null;

			try {
				//(1):创建sql对象
				statement = connection.createStatement();
				//(2)：执行相关的查询语句
				rs = statement.executeQuery(sql);
			} catch (SQLException e) {
				e.printStackTrace();
			}
			return rs;
		}

//3、使用带多个问号的方式封装动态sql的查询【★★★★★】
		/**
		 * @param sql：是需要执行的查询，可以带问号或者不带问号。
		 * @param ...：代表不可预估的带问号的个数。
		 * @param params：在sql中需要的参数
		 * @return	【执行查询】
		 */
		public ResultSet excuteQuery(String sql , Object ... params ){

			PreparedStatement preparedStatement;
			ResultSet resultSet = null;

			try {
				//调取执行sql的方法，
				preparedStatement = connection.prepareStatement(sql);

				//判断sql语句中是否带有？。
				if (params != null && params.length > 0){
					//如果有就对问号进行赋值
					for (int i = 0; i < params.length; i++) {
					preparedStatement.setObject(i+1 , params[i] );
					}
				}

				resultSet = preparedStatement.executeQuery();

			} catch (SQLException e) {
				e.printStackTrace();
			}

			return resultSet;
		}
}

（3）、新建一个JdbcTest类，带有主函数。

package www.com.c2;

import java.sql.ResultSet;

//主要调取封装的动态sql的方法，

public class JdbcTest {

	public static void main(String[] args) {

		JdbcMethod jdbcMethod = new JdbcMethod();

	//创建相应的sql语句去操作数据表。
		int inser = jdbcMethod.excuteUpdate("insert into emp values()");
		int update = jdbcMethod.excuteUpdate("update emp set  where");
		int delete = jdbcMethod.excuteUpdate("delete from emp where....");

	//2、执行查询语句、返回的是结果集
		ResultSet resultSet = jdbcMethod.excuteQuery("select* from emp where ");
	}
}

四、结束语

到这里我们就把JDBC的一些常用的方法说完了，记住，连接数据库无须就对表中数据的增删改查。一定要掌握使用动态sql的方法去操作数据库和思想。