前言

当我们学完数据库之后总觉得数据库和java之间是没有联系的，但是我们还是要去学数据库是为了什么呐？现在就来了，现在我就来给大家讲讲怎么将数据库和java进行联系，我们也可以用数据库代替以前的IO流来存东西了。

 JDBC

概述

JDBC(Java Database Connectivity)是一个独立于特定数据库管理系统、通用的SQL数据库存取和操作的公共接口（一组API），定义了用来访问数据库的标准Java类库，（java.sql,javax.sql）使用这些类库可以以一种标准的方法、方便地访问数据库资源。

JDBC为访问不同的数据库提供了一种统一的途径，为开发者屏蔽了一些细节问题。

JDBC的目标是使Java程序员使用JDBC可以连接任何**提供了JDBC驱动程序**的数据库系统，这样就使得程序员无需对特定的数据库系统的特点有过多的了解，从而大大简化和加快了开发过程。

JDBC程序编写步骤

 

获取数据库连接

要素一：Driver接口实现类

我们在链接数据库之前我们需要一个Driver接口的实现类，但是我们的java中又没有自带这个包所以我们需要往我们的工程文件中添加一个MySQL的jar包才能使用相关的东西。

我们在idea中的操作是这样的：

先找到项目的添加的地方

 

再点如图的加号

 

然后点第一个

 

我们就可以从我们保存的目录中导入需要的包了

要素二：URL

JDBC URL 用于标识一个被注册的驱动程序，驱动程序管理器通过这个 URL 选择正确的驱动程序，从而建立到数据库的连接。  我以MySQL为例我们常用的就是入下的样子

 

要素三：用户名和密码

user,password可以用“属性名=属性值”方式告诉数据库

可以调用 DriverManager 类的 getConnection() 方法建立到数据库的连接

前面的三步就是我们需要获取连接必要的三部。

实现代码：

	//1.加载配置文件InputStream is = ConnectionTest.class.getClassLoader().getResourceAsStream("jdbc.properties");Properties pros = new Properties();pros.load(is);//2.读取配置信息String user = pros.getProperty("user");String password = pros.getProperty("password");String url = pros.getProperty("url");String driverClass = pros.getProperty("driverClass");//3.加载驱动Class.forName(driverClass);//4.获取连接Connection conn = DriverManager.getConnection(url,user,password);System.out.println(conn);

 其中，配置文件声明在工程的src目录下：【jdbc.properties】

user=root
password=abc123
url=jdbc:mysql://localhost:3306/test
driverClass=com.mysql.jdbc.Driver

而我们使用配置文件的好处就是：

①实现了代码和数据的分离，如果需要修改配置信息，直接在配置文件中修改，不需要深入代码 ②如果修改了配置信息，省去重新编译的过程。

 

使用PreparedStatement实现查询操作

当我们获得了连接之后我们就需要进行操作了，首先我们需要一个同用的查询

// 通用的针对于不同表的查询:返回一个对象 (version 1.0)public <T> T getInstance(Class<T> clazz, String sql, Object... args) {Connection conn = null;PreparedStatement ps = null;ResultSet rs = null;try {// 1.获取数据库连接conn = JDBCUtils.getConnection();// 2.预编译sql语句，得到PreparedStatement对象ps = conn.prepareStatement(sql);// 3.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 4.执行executeQuery(),得到结果集：ResultSetrs = ps.executeQuery();// 5.得到结果集的元数据：ResultSetMetaDataResultSetMetaData rsmd = rs.getMetaData();// 6.1通过ResultSetMetaData得到columnCount,columnLabel；通过ResultSet得到列值int columnCount = rsmd.getColumnCount();if (rs.next()) {T t = clazz.newInstance();for (int i = 0; i < columnCount; i++) {// 遍历每一个列// 获取列值Object columnVal = rs.getObject(i + 1);// 获取列的别名:列的别名，使用类的属性名充当String columnLabel = rsmd.getColumnLabel(i + 1);// 6.2使用反射，给对象的相应属性赋值Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnVal);}return t;}} catch (Exception e) {e.printStackTrace();} finally {// 7.关闭资源JDBCUtils.closeResource(conn, ps, rs);}return null;}

获取连接的封装：

   public static Connection getConnection()throws Exception{InputStream is =Connectiontest.class.getClassLoader().getResourceAsStream("jdbc.properties");Properties pros=new Properties();pros.load(is);String user=pros.getProperty("user");String password=pros.getProperty("password");String url=pros.getProperty("url");String driverName=pros.getProperty("driverName");Class.forName(driverName);Connection conn=DriverManager.getConnection(url,user,password);return conn;}

关闭流的操作：

 public static void closeResource(Connection conn, Statement ps,ResultSet rs){try{if(ps!=null)ps.close();}catch (SQLException e){e.printStackTrace();}try{if(conn!=null)conn.close();}catch (SQLException e){e.printStackTrace();}try{if(rs !=null)rs.close();}catch (SQLException e){e.printStackTrace();}}

 查询的样子：

 System.out.println("请输入需要查询的用户名称：");Scanner sc=new Scanner(System.in);String a=sc.next();String sql="select employee_id id,first_name name from employees where first_name=? ";employees instance = getInstance(employees.class, sql, a);System.out.println(instance);

 而其中的那个employees是我们需要查询的表所对应的实体类，实体类里面的属性和表中的列名相对应。

使用PreparedStatement实现增、删、改操作

由于增删改的操作都差不多所以可以由一个通用的来实现：

//通用的增、删、改操作（体现一：增、删、改 ； 体现二：针对于不同的表）public void update(String sql,Object ... args){Connection conn = null;PreparedStatement ps = null;try {//1.获取数据库的连接conn = JDBCUtils.getConnection();//2.获取PreparedStatement的实例 (或：预编译sql语句)ps = conn.prepareStatement(sql);//3.填充占位符for(int i = 0;i < args.length;i++){ps.setObject(i + 1, args[i]);}//4.执行sql语句ps.execute();} catch (Exception e) {e.printStackTrace();}finally{//5.关闭资源JDBCUtils.closeResource(conn, ps);}}

获取流和上面的查找一样，只有关闭流会少一个如下：

 public static void closeResource(Connection conn, Statement ps){try{if(ps!=null)ps.close();}catch (SQLException e){e.printStackTrace();}try{if(conn!=null)conn.close();}catch (SQLException e){e.printStackTrace();}}

 操作实现：

String sql1="delete from employees where employee_id=?";update(sql1,101);

总结

总的JDBC的常规操作就是以上的，首先我们需要导入我们需要的包，然后就是进行获取连接，然后得到连接之后我们就需要进行各种操作。希望对大家有所帮助。