java怎么从数据库获取数据

核心技术体系

Java与数据库交互的核心依赖于JDBC（Java Database Connectivity）标准接口，该规范定义了一套统一的API用于连接各类关系型数据库，实际开发中需结合以下组件协同工作：
| 层级 | 作用 | 典型代表 |
|————-|——————————-|—————————|
| 驱动层 | 实现JDBC接口的具体数据库适配 | MySQL Connector/J |
| 连接管理层 | 维护数据库物理连接 | Druid/HikariCP连接池 |
| SQL执行层 | 解析并执行SQL语句 | Statement/PreparedStatement|
| 结果处理层 | 封装查询结果 | ResultSet/实体对象映射 |
| ORM层 | 对象-关系映射 | MyBatis/Hibernate/JPA |

基础实现流程（基于纯JDBC）

环境准备

• 添加依赖：根据目标数据库选择对应驱动包（如mysql-connector-java-8.0.xx.jar）
• 注册驱动：通过Class.forName("com.mysql.cj.jdbc.Driver")显式加载驱动类
• 构建连接URL：格式为jdbc:mysql://host:port/dbname?useSSL=false&serverTimezone=UTC

标准操作五步曲

// 1. 加载驱动（新版JDBC可省略此步）
Class.forName("com.mysql.cj.jdbc.Driver");
// 2. 建立连接
Connection conn = DriverManager.getConnection(url, user, password);
// 3. 创建执行器（推荐使用PreparedStatement防SQL注入）
String sql = "SELECT  FROM users WHERE age > ?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, 18); // 设置参数值
// 4. 执行查询
ResultSet rs = pstmt.executeQuery();
// 5. 遍历结果集
while(rs.next()){
    int id = rs.getInt("id");
    String name = rs.getString("username");
    // ...其他字段处理
}
// 6. 释放资源（务必按反向顺序关闭）
rs.close();
pstmt.close();
conn.close();

关键注意事项

连接池优化方案

生产环境必须使用连接池替代直连模式，主流实现对比如下：
| 特性 | Druid | HikariCP | C3P0 |
|———————|——————————–|——————————|—————————|
| 性能表现 | ★★★☆ | ★★★★★（目前最快） | ★★★☆ |
| 监控功能 | 内置Web监控面板 | 基础指标 | 较弱 |
| 配置复杂度 | 中等 | 极简（默认配置即可生效） | 较高 |
| 特殊功能 | SQL防火墙/慢查询日志 | 无感集成Spring Boot | JMX支持 |

Druid配置示例：

# application.properties
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.url=jdbc:mysql://localhost:3306/test?useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# 连接池核心参数
spring.datasource.initial-size=5
spring.datasource.max-active=20
spring.datasource.min-idle=5
spring.datasource.max-wait=60000 # 超时时间毫秒

ORM框架应用实践

MyBatis基础用法

Mapper接口定义：

public interface UserMapper {
    User selectById(@Param("id") Long id);
    List<User> selectAll();
}

XML映射文件：

<!-UserMapper.xml -->
<select id="selectById" resultType="com.example.User">
    SELECT  FROM users WHERE id = #{id}
</select>
<select id="selectAll" resultMap="userMap">
    SELECT u., r.role_name AS roleName 
    FROM users u
    LEFT JOIN roles r ON u.role_id = r.id
</select>

动态SQL示例：

<select id="findUsers" parameterType="map" resultType="User">
    SELECT  FROM users
    <where>
        <if test="name != null">AND name LIKE CONCAT('%',#{name},'%')</if>
        <if test="minAge != null">AND age >= #{minAge}</if>
    </where>
    ORDER BY create_time DESC
    <if test="startIndex != null and pageSize != null">
        LIMIT #{startIndex},#{pageSize}
    </if>
</select>

JPA/Hibernate核心概念

复杂场景解决方案

批量数据处理

分布式事务处理

常见错误排查指南

相关问答FAQs

Q1: 如何防止SQL注入攻击？

A: 最有效的方法是始终使用PreparedStatement代替Statement，并通过问号占位符(?)传递参数。

// 安全做法
String sql = "SELECT  FROM users WHERE email = ?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, userInputEmail); // 自动转义特殊字符
// 危险做法（易受注入）
Statement stmt = conn.createStatement();
String badSql = "SELECT  FROM users WHERE email = '" + userInputEmail + "'"; // 若输入含' OR '1'='1则会被执行

补充措施：①对输入进行白名单校验 ②启用数据库防火墙 ③定期审计慢查询日志。

Q2: 查询百万级数据时出现OOM怎么办？

A: 采用以下组合策略解决：

1. 分页查询：SELECT FROM table LIMIT 100000, 100（注意偏移量大时效率低）
2. 游标机制：conn.setHoldability(ResultSet.HOLD_CURSORS_OVER_COMMIT)保持游标打开
3. 流式处理：rs.setFetchSize(Integer.MIN_VALUE)禁用全量加载到内存
4. 投影优化：仅查询必要字段而非SELECT
5. 异步处理：将结果写入临时文件/消息队列，后续分段处理
6. 数据库层面优化：添加合适索引,考虑分区表设计。