原生Jdbc获取库、表、字段

「爱情、让人受尽委屈。」 2023-10-12 19:17 10阅读 0赞

### 文章目录 ###

*   *  一、简介
     *   *  1、概述
         *  2、Jdbc获取连接
         *  3、执行器
     *  二、获取链接
     *   *  1、获取链接
         *  2、关闭连接
         *  3、Statement
         *  4、PrepatedStatement
         *  5、 ResultSet
         *  6、ResultSetMetaData
     *  三、执行SQL
     *   *  2.1 增/删/改
         *  2.2 查询
     *  四、获取库、表结构
     *   *  1、获取Catalog
         *  2、获取库列表
         *  3、获取表名
         *  4、获取字段

--------------------

## 一、简介 ##

### 1、概述 ###

*  JDBC(Java Database Connectivity)是一个**独立于特定数据库管理系统、通用的SQL数据库存取和操作的公共接口**（一组API），定义了用来访问数据库的标准Java类库，（**java.sql,javax.sql**）使用这些类库可以以一种**标准**的方法、方便地访问数据库资源。
 *  JDBC为访问不同的数据库提供了一种**统一的途径**，为开发者屏蔽了一些细节问题。
 *  JDBC的目标是使Java程序员使用JDBC可以连接任何**提供了JDBC驱动程序**的数据库系统，这样就使得程序员无需对特定的数据库系统的特点有过多的了解，从而大大简化和加快了开发过程。

![在这里插入图片描述][3010938bc40e4511ade0abcda7d15088.png]

### 2、Jdbc获取连接 ###

![在这里插入图片描述][b8f8dbc1fc2c45e18f0e5fc3f57c39ca.png]

*  1、加载驱动
 *  2、建立连接
 *  3、创建Statement对象
 *  4、执行SQL
 *  5、关闭连接

String jdbcdriver = "";
    String url = "";
    String username = "";
    String password = "";
    String sql = "";
    //    1、加载驱动
    Class.forName(jdbcdriver);
    //    2、建立连接
    Connection conn = DriverManager.getConnection(url, username, password);
    //    3、创建Statement对象
    PreparedStatement ps = conn.prepareStatement(sql);
    //    4、执行SQL
    ps.executeQuery();
    //    5、关闭连接
    conn.close();
    ps.close();
    closeConn(conn, ps);

### 3、执行器 ###

在 java.sql 包中有 3 个接口分别定义了对数据库的调用的不同方式：

*  `Statement`：用于执行静态 SQL 语句并返回它所生成结果的对象。
 *  `PrepatedStatement`：SQL 语句被预编译并存储在此对象中，可以使用此对象多次高效地执行该语句。
 *  `CallableStatement`：用于执行 SQL 存储过程

![在这里插入图片描述][ae8678ac687346dfa7db1f252e1694d1.png]

## 二、获取链接 ##

### 1、获取链接 ###

//    1、加载驱动
     Class.forName(jdbcdriver);
     //    2、建立连接
     Connection conn = DriverManager.getConnection(url, username, password);

### 2、关闭连接 ###

//    5、关闭连接
    conn.close();
    ps.close();
    closeConn(conn, ps);

public static <T> void close(T... t) {
        
        for (T one : t) {
        
            if (one instanceof AutoCloseable) {
        
                try {
        
                    ((AutoCloseable) one).close();
                } catch (Exception e) {
        
                    e.printStackTrace();
                }
            }
        }
    }

方式二：

/**
     * 
     * @Description 关闭资源操作
     * @author shkstart
     * @date 上午10:21:15
     * @param conn
     * @param ps
     * @param rs
     */
    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();
    	}
    }

### 3、Statement ###

`Statement`：用于执行静态 SQL 语句并返回它所生成结果的对象。

但是使用Statement操作数据表存在弊端：

*  **问题一：存在拼串操作，繁琐**
 *  **问题二：存在SQL注入问题**

// 1、加载驱动
    Class.forName(driverClass);
    // 2、获取连接
    Connection conn = DriverManager.getConnection(url, user, password);
    //	3、获取执行器
    Statement st = conn.createStatement();
    //	4、执行查询
    ResultSet rs = st.executeQuery(sql);
    //	5、获取结果集的元数据
    ResultSetMetaData rsmd = rs.getMetaData();

### 4、PrepatedStatement ###

`PrepatedStatement`：SQL 语句被预编译并存储在此对象中，可以使用此对象多次高效地执行该语句。

*  可以通过调用 Connection 对象的 **preparedStatement(String sql)** 方法获取 PreparedStatement 对象
 *  **PreparedStatement 接口是 Statement 的子接口，它表示一条预编译过的 SQL 语句**
 *  PreparedStatement 对象所代表的 SQL 语句中的参数用问号(?)来表示，调用 PreparedStatement 对象的 setXxx() 方法来设置这些参数. setXxx() 方法有两个参数，第一个参数是要设置的 SQL 语句中的参数的索引(从 1 开始)，第二个是设置的 SQL 语句中的参数的值

**使用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);
    			
    		}
    	}

**使用PreparedStatement实现查询操作**

### 5、 ResultSet ###

**问题1：得到结果集后, 如何知道该结果集中有哪些列 ？ 列名是什么？**

需要使用一个描述 ResultSet 的对象， 即 ResultSetMetaData

![在这里插入图片描述][50813587a16b43f7aca37e93a51e68a7.png]

*  查询需要调用PreparedStatement 的 executeQuery() 方法，查询结果是一个ResultSet 对象
 *  ResultSet 对象以逻辑表格的形式封装了执行数据库操作的结果集，ResultSet 接口由数据库厂商提供实现
 *  ResultSet 返回的实际上就是一张数据表。有一个指针指向数据表的第一条记录的前面。
 *  ResultSet 对象维护了一个指向当前数据行的**游标**，初始的时候，游标在第一行之前，可以通过 ResultSet 对象的 next() 方法移动到下一行。调用 next()方法检测下一行是否有效。若有效，该方法返回 true，且指针下移。相当于Iterator对象的 hasNext() 和 next() 方法的结合体。
 *  当指针指向一行时, 可以通过调用 getXxx(int index) 或 getXxx(int columnName) 获取每一列的值。
    
     *  例如: getInt(1), getString(“name”)
     *  **注意：Java与数据库交互涉及到的相关Java API中的索引都从1开始。**
 *  ResultSet 接口的常用方法：
    
     *  boolean next()
     *  getString()
     *  …
    
    ![在这里插入图片描述][d85434b087b1492ea2b0a29921b9671f.png]

### 6、ResultSetMetaData ###

用于获取关于 ResultSet 对象中列的类型和属性信息的对象

ResultSetMetaData meta = rs.getMetaData( );

*  `getColumnName(int column)`：获取指定列的名称。
 *  `getColumnLabel(int column)`：获取指定列的别名。
 *  `getColumnCount()`：返回当前 ResultSet 对象中的列数。
 *  `getColumnTypeName(int column)`：检索指定列的数据库特定的类型名称。
 *  `getColumnDisplaySize(int column)`：指示指定列的最大标准宽度，以字符为单位。
 *  `isNullable(int column)`：指示指定列中的值是否可以为 null。
 *  `isAutoIncrement(int column)`：指示是否自动为指定列进行编号，这样这些列仍然是只读的。

![在这里插入图片描述][4c23cf299acc42a28de64b72aca9b435.png]

## 三、执行SQL ##

### 2.1 增/删/改 ###

### 2.2 查询 ###

使用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(),得到结果集：ResultSet
    			rs = ps.executeQuery();
    
    			// 5.得到结果集的元数据：ResultSetMetaData
    			ResultSetMetaData 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;
    
    	}

## 四、获取库、表结构 ##

### 1、获取Catalog ###

/**
     * 获取catalog
     *
     * @param jdbcdriver 驱动类(DriverClass)(com.mysql.cj.jdbc.Driver)
     * @param url        地址(jdbc:mysql://10.20.30.40:3306)
     * @param username   用户名
     * @param password   密码
     */
    public List<String> getCatalogs(String jdbcdriver, String url, String username, String password) throws ClassNotFoundException, SQLException {
        
        ArrayList<String> list = new ArrayList<>();
        //    1、加载驱动
        Class.forName(jdbcdriver);
        //    2、建立连接
        Connection conn = DriverManager.getConnection(url, username, password);
        try {
        
            DatabaseMetaData metaData = conn.getMetaData();
            ResultSet resultSet = metaData.getCatalogs();
            while (resultSet.next()) {
        
                String string = resultSet.getString("TABLE_CAT");
                list.add(string);
            }
        } catch (SQLException e) {
        
            e.printStackTrace();
        } finally {
        
            conn.close();
        }
        return list;
    }

### 2、获取库列表 ###

/**
     * 获取数据库
     *
     * @param jdbcdriver 驱动类(DriverClass)(com.mysql.cj.jdbc.Driver)
     * @param url        地址(jdbc:mysql://10.20.30.40:3306)
     * @param username   用户名
     * @param password   密码
     * @param catalogs   catalogs
     */
    public List<String> getDatabase(String jdbcdriver, String url, String username, String password, String catalogs) throws ClassNotFoundException, SQLExcepti
        ArrayList<String> list = new ArrayList<>();
        //    1、加载驱动
        Class.forName(jdbcdriver);
        //    2、建立连接
        Connection conn = DriverManager.getConnection(url, username, password);
        try {
        
            DatabaseMetaData metaData = conn.getMetaData();
            ResultSet resultSet = metaData.getSchemas(catalogs, null);
            //  没有catalog可以采用下面这种方式
            //  ResultSet resultSet = metaData.getSchemas();
            while (resultSet.next()) {
        
                String string = resultSet.getString("TABLE_SCHEM");
                list.add(string);
            }
        } catch (SQLException e) {
        
            e.printStackTrace();
        } finally {
        
            conn.close();
        }
        return list;
    }

### 3、获取表名 ###

/**
     * 获取表
     *
     * @param jdbcdriver 驱动类(DriverClass)(com.mysql.cj.jdbc.Driver)
     * @param url        地址(jdbc:mysql://10.20.30.40:3306)
     * @param username   用户名
     * @param password   密码
     * @param catalogs   catalogs
     * @param database   数据库
     */
    public List<String> getTables(String jdbcdriver, String url, String username, String password, String catalogs, String database) throws ClassNotFoundException, SQLException {
        
        List<String> list = new ArrayList<>();
        //    1、加载驱动
        Class.forName(jdbcdriver);
        //    2、建立连接
        Connection conn = DriverManager.getConnection(url, username, password);
        try {
        
            DatabaseMetaData metaData = conn.getMetaData();
            ResultSet tables = metaData.getTables(
                    catalogs,
                    database,
                    "%",
                    new String[]{
        "TABLE", "VIEW"});
            while (tables.next()) {
        
                String name = tables.getString("TABLE_NAME");
                list.add(name);
            }
        } catch (SQLException e) {
        
            e.printStackTrace();
        } finally {
        
            conn.close();
        }
        return list;
    }

### 4、获取字段 ###

/**
     * 获取字段
     *
     * @param jdbcdriver 驱动类(DriverClass)(com.mysql.cj.jdbc.Driver)
     * @param url        地址(jdbc:mysql://10.20.30.40:3306)
     * @param username   用户名
     * @param password   密码
     * @param catalogs   catalogs
     * @param database   库
     * @param table      表
     */
    public List<JSONObject> getColumns(String jdbcdriver, String url, String username, String password, String catalogs, String database) throws ClassNotFoundException, SQLException {
        
        List<JSONObject> list = new ArrayList<>();
        //    1、加载驱动
        Class.forName(jdbcdriver);
        //    2、建立连接
        Connection conn = DriverManager.getConnection(url, username, password);
        try {
        
            DatabaseMetaData metaData = conn.getMetaData();
            ResultSet rs = metaData.getColumns(catalogs, database, table, "%");
            while (rs.next()) {
        
                JSONObject json = new JSONObject();
                //  列明
                json.put("columnName", rs.getString("COLUMN_NAME"));
                //  列类型
                json.put("typeName", rs.getString("TYPE_NAME"));
                //  列备注
                json.put("remarks", rs.getString("REMARKS"));
                list.add(json);
            }
        } catch (Exception e) {
        
            e.printStackTrace();
        } finally {
        
            conn.close();
        }
        return list;
    }

[3010938bc40e4511ade0abcda7d15088.png]: https://img-blog.csdnimg.cn/3010938bc40e4511ade0abcda7d15088.png
[b8f8dbc1fc2c45e18f0e5fc3f57c39ca.png]: https://img-blog.csdnimg.cn/b8f8dbc1fc2c45e18f0e5fc3f57c39ca.png
[ae8678ac687346dfa7db1f252e1694d1.png]: https://img-blog.csdnimg.cn/ae8678ac687346dfa7db1f252e1694d1.png
[50813587a16b43f7aca37e93a51e68a7.png]: https://img-blog.csdnimg.cn/50813587a16b43f7aca37e93a51e68a7.png
[d85434b087b1492ea2b0a29921b9671f.png]: https://img-blog.csdnimg.cn/d85434b087b1492ea2b0a29921b9671f.png
[4c23cf299acc42a28de64b72aca9b435.png]: https://img-blog.csdnimg.cn/4c23cf299acc42a28de64b72aca9b435.png