jdbc总结

JDBC介绍
JDBC（Java Database Connectivity）是Java和数据库之间的一个桥梁，是一个规范而不是一个实现，能够执行SQL语句。它由一组用Java语言编写的类和接口组成。各种不同类型的数据库都有相应的实现，本文中的代码都是针对MySQL数据库实现的。

JDBC编程步骤 
1.装载相应数据库的JDBC驱动并进行初始化
导入专用的jar包（不同的数据库需要的jar包不同）
        访问MySQL数据库需要用到第三方的类，这些第三方的类，都被压缩在一个.Jar的文件里。mysql-connector-java-5.0.8-bin.jar包可以在网上下载，或者在MySQL的安装目录下找到。通常下载到该jar包之后将其放到在项目的lib目录下，在本例就会放在E:projectj2selib 这个位置，然后在eclipse中导入这个jar包。

        导包步骤： 右键project->property->java build path->libaries->add external jars

初始化驱动

      通过初始化驱动类com.mysql.jdbc.Driver，该类就在 mysql-connector-java-5.0.8-bin.jar中。如果你使用的是oracle数据库那么该驱动类将不同。

        注意：Class.forName需要捕获ClassNotFoundException.
 

try {
        Class.forName("com.mysql.jdbc.Driver");		
        } catch (ClassNotFoundException e) { 				
            e.printStackTrace();
        }

Class.forName是把这个类加载到JVM中，加载的时候，就会执行其中的静态初始化块，完成驱动的初始化的相关工作。 

2.建立JDBC和数据库之间的Connection连接
这里需要提供：数据库服务端的IP地址:127.0.0.1 (这是本机，如果连接其他电脑上的数据库，需填写相应的IP地址)
                         数据库的端口号： 3306 （mysql专用端口号）
                         数据库名称 exam（根据你自己数据库中的名称填写）
                         编码方式 UTF-8
                         账号 root
                         密码 admin（如果你在创建数据库的时候没有使用默认的账号和密码，请填写自己设置的账号和密码）
 

Connection c = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/exam?characterEncoding=UTF-8", "root", "admin");

package Day_32.com;

import java.io.BufferedReader;
import java.io.FileReader;
import java.util.HashMap;
import java.util.Map;

public class ConfigUtil {
	private static Map data = new HashMap();
	static {
		try (BufferedReader br = new BufferedReader(new FileReader(
				"./src/jdbc.properties"));) {
			String temp = null;
			while ((temp = br.readLine()) != null) {
				int index = temp.indexOf("=");
				String key = temp.substring(0, index);
				String value = temp.substring(index + 1);
				data.put(key, value);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static String get(String key) {
		return data.get(key);
	}
}

package Day_32.com;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DBUtil {
	public static Connection getConnection() throws SQLException,
			ClassNotFoundException {
		// 1 加载驱动
		Class.forName("com.mysql.jdbc.Driver");
		// 2 链接对象
		// 导的所有包都是 java.sql的
		// jdbc:mysql://IP:端口/数据库 用户名 密码
		return DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/day_03",
				"root", "root");
	}
	// AutoCloseable 是 Connection,Statement,ResultSet的父类
	public static void close(AutoCloseable obj){
	if (obj != null) {
		try {
			obj.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
//	public static void close(Connection conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void close(Statement conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void close(ResultSet conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void close(PreparedStatement conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void closeConnection(Connection conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void closeStatement(Statement conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void closeResultSet(ResultSet conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	public static void closePreparedStatement(PreparedStatement conn){
//		if (conn != null) {
//			try {
//				conn.close();
//			} catch (SQLException e) {
//				e.printStackTrace();
//			}
//		}
//	}
}

package Day_32.com;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;


public class JDBC_01_base {
	public static void main(String[] args) throws Exception {
		// 1 加载驱动
		Class.forName("com.mysql.jdbc.Driver");
		// 2 链接对象
		// 导的所有包都是 java.sql的
		// jdbc:mysql://IP:端口/数据库 用户名 密码
		Connection conn = DriverManager.getConnection(
				"jdbc:mysql://127.0.0.1:3306/day_03", "root", "root");

		// 3 创建语句传输对象
		String sql = "select * from student";
		Statement stmt = conn.createStatement();

		// 4 执行并获取结果
		ResultSet rs = stmt.executeQuery(sql);
		// next() : 判断下面是否还有数据,如果有就指向下一个数据
		// 遍历获取数据
		while (rs.next()) {
			// 获取第几列的数据
			// System.out.print( rs.getInt(1) );
			// 根据列名获取数据
			System.out.print(rs.getInt("sid")+" ");
			System.out.print(rs.getString("sname")+" ");
			System.out.println();
		}
		System.out.println("连接成功");
		// 关闭资源
		rs.close();
		stmt.close();
		conn.close();
	}
}

Connection是与特定数据库连接回话的接口，使用的时候需要导包，而且必须在程序结束的时候将其关闭。getConnection方法也需要捕获SQLException异常。

因为在进行数据库的增删改查的时候都需要与数据库建立连接，所以可以在项目中将建立连接写成一个工具方法，用的时候直接调用即可：

        
public static Connection getConnection(){
		Connection conn = null;
		 try {
			 	//初始化驱动类com.mysql.jdbc.Driver
	            Class.forName("com.mysql.jdbc.Driver");
	            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/exam?characterEncoding=UTF-8","root", "admin");
	            //该类就在 mysql-connector-java-5.0.8-bin.jar中,如果忘记了第一个步骤的导包，就会抛出ClassNotFoundException
	        } catch (ClassNotFoundException e) { 				
	            e.printStackTrace();
	        }catch (SQLException e) {							
	            e.printStackTrace();
	        }
		 return conn;
	}

3.创建Statement或者PreparedStatement接口，执行SQL语句
使用Statement接口
Statement接口创建之后，可以执行SQL语句，完成对数据库的增删改查。其中 ，增删改只需要改变SQL语句的内容就能完成，然而查询略显复杂。在Statement中使用字符串拼接的方式，该方式存在句法复杂，容易犯错等缺点，具体在下文中的对比中介绍。所以Statement在实际过程中使用的非常的少，所以具体的放到PreparedStatement那里给出详细代码。

字符串拼接方式的SQL语句是非常繁琐的，中间有很多的单引号和双引号的混用，极易出错。
 

Statement s = conn.createStatement();
// 准备sql语句
// 注意： 字符串要用单引号'
String sql = "insert into t_courses values(null,"+"'数学')";
//在statement中使用字符串拼接的方式，这种方式存在诸多问题
s.execute(sql);
System.out.println("执行插入语句成功");

使用PreparedStatement接口
与 Statement一样，PreparedStatement也是用来执行sql语句的与创建Statement不同的是，需要根据sql语句创建PreparedStatement。除此之外，还能够通过设置参数，指定相应的值，而不是Statement那样使用字符串拼接。

给数据库中添加课程： （以下代码中最后关闭资源的两个方法 DbUtil.close(pstmt);  DbUtil.close(conn);  和上面的建立连接的方法是一样的，是在工具类中定义了的关闭方法，下文会给出其代码）

        
	public void addCourse(String courseName){
		String sql = "insert into t_course(course_name) values(?)";  
 //该语句为每个 IN 参数保留一个问号（“？”）作为占位符
		Connection conn = null;				//和数据库取得连接
		PreparedStatement pstmt = null;		//创建statement
		try{
			conn = DbUtil.getConnection();
			pstmt = (PreparedStatement) conn.prepareStatement(sql);
			pstmt.setString(1, courseName); //给占位符赋值
			pstmt.executeUpdate();			//执行
		}catch(SQLException e){
			e.printStackTrace();
		}
		finally{
			DbUtil.close(pstmt);
			DbUtil.close(conn);		//必须关闭
		}
	}

对数据库中的课程进行删除： 

        
	public void delCourse(int courseId){
		String sql = "delete from t_course where course_id = ?";
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = DbUtil.getConnection();
			pstmt = (PreparedStatement) conn.prepareStatement(sql);
			pstmt.setInt(1, courseId);
			pstmt.executeUpdate();
		} catch (SQLException e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			DbUtil.close(pstmt);
			DbUtil.close(conn);		//必须关闭
		}
	}

对数据库中的课程进行修改：

        
	public void modifyCourse(int courseId,String courseName){
		String sql = "update t_course set course_name =? where course_id=?";
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = DbUtil.getConnection();
			pstmt = (PreparedStatement) conn.prepareStatement(sql);
			pstmt.setString(1, courseName);  //利用Preparedstatement的set方法给占位符赋值
			pstmt.setInt(2, courseId);
			pstmt.executeUpdate();
		} catch (SQLException e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			DbUtil.close(pstmt);
			DbUtil.close(conn);		//必须关闭
		}
	}

5.释放资源
在JDBC编码的过程中我们创建了Connection、ResultSet等资源，这些资源在使用完毕之后是一定要进行关闭的。关闭的过程中遵循从里到外的原则。因为在增删改查的操作中都要用到这样的关闭操作，为了使代码简单，增加其复用性，这里我将这些关闭的操作写成一个方法和建立连接的方法一起放到一份工具类中。
 

	public static void close(PreparedStatement pstmt){
		if(pstmt != null){						//避免出现空指针异常
			try{
				pstmt.close();
			}catch(SQLException e){
				e.printStackTrace();
			}
			
		}
	}
	
	public static void close(Connection conn){
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO: handle exception
				e.printStackTrace();
			}
		}
	}
	
	public static void close(ResultSet rs){
		if (rs != null) {
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO: handle exception
				e.printStackTrace();
			}
		}
	}