Java读取数据库表

Java读取数据库表

1. package com.easycrud.builder;
3. import com.easycrud.utils.PropertiesUtils;
4. import org.slf4j.Logger;
5. import org.slf4j.LoggerFactory;
6. import java.sql.*;
8. /**
9. * @BelongsProject: EasyCrud
10. * @BelongsPackage: com.easycrud.builder
11. * @Author: xpx
12. * @Email: 2436846019@qq.com
13. * @CreateTime: 2023-05-02  18:02
14. * @Description: 读Table
15. * @Version: 1.0
16. */
18. public class BuildTable {
20.     private static final Logger logger = LoggerFactory.getLogger(BuildTable.class);
21.     private static Connection conn = null;
23.     /**
24.      * 查表名和表注释
25.      */
26.     private static String SQL_SHOW_TABLE_STATUS = "show table status";
28.     /**
29.      * 读配置,连接数据库
30.      */
31.     static {
32.         String driverName = PropertiesUtils.getString("db.driver.name");
33.         String url = PropertiesUtils.getString("db.url");
34.         String user = PropertiesUtils.getString("db.username");
35.         String password = PropertiesUtils.getString("db.password");
37.         try {
38.             Class.forName(driverName);
39.             conn = DriverManager.getConnection(url,user,password);
40.         } catch (Exception e) {
41.             logger.error("数据库连接失败",e);
42.         }
43.     }
45.     /**
46.      * 读取表
47.      */
48.     public static void getTables() {
49.         PreparedStatement ps = null;
50.         ResultSet tableResult = null;
52.         try{
53.             ps = conn.prepareStatement(SQL_SHOW_TABLE_STATUS);
54.             tableResult = ps.executeQuery();
55.             while(tableResult.next()) {
56.                 String tableName = tableResult.getString("name");
57.                 String comment = tableResult.getString("comment");
58.                 logger.info("tableName:{},comment:{}",tableName,comment);
59.             }
60.         }catch (Exception e){
61.             logger.error("读取表失败",e);
62.         }finally {
63.             if (tableResult != null) {
64.                 try {
65.                     tableResult.close();
66.                 } catch (SQLException e) {
67.                     e.printStackTrace();
68.                 }
69.             }
70.             if (ps != null) {
71.                 try {
72.                     ps.close();
73.                 } catch (SQLException e) {
74.                     e.printStackTrace();
75.                 }
76.             }
77.             if (conn != null) {
78.                 try {
79.                     conn.close();
80.                 } catch (SQLException e) {
81.                     e.printStackTrace();
82.                 }
83.             }
84.         }
85.     }
86. }

复制代码

新手引导

Logger

Java自带的日志。
常见用法如下，打印日志信息：
logger.error("数据库连接失败",e)
logger.info("tableName:{},comment:{}",tableName,comment)，{}是占位符

LoggerFactory.getLogger(xxx.class)

指定类初始化日志对象，在日志输出的时候，可以打印出日志信息所在类。

Connection

Connection 对象用于打开与数据源的连接。

Class.forName(driverName)

加载驱动程序。

DriverManager.getConnection(url,user,password)

获取数据库连接。

PreparedStatement

用来执行SQL查询语句的 API 之一。

ResultSet

结果集 (ResultSet) 是数据中查询结果返回的一种对象，结果集是一个存储查询结果的对象。

ps = conn.prepareStatement(SQL_SHOW_TABLE_STATUS)

执行前会对SQL语句进行预编译的操作，然后就开始执行SQL语句，并返回结果。

tableResult = ps.executeQuery()

把数据库响应的查询结果存放在ResultSet类对象中供我们使用。

ResultSet中next()方法

ResultSet中指针的初始位置位于第一行之前；第一次调用next()方法将会把第一行设置为当前行。

name和comment

分别代表执行数据库show table status语句后查询出的表名和表注释。配合ResultSet的getString()方法得到对应值。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！