java可通过反射+自定义注解动态生成mysql insert语句：定义@table、@column等注解标记映射关系，反射获取类信息与字段值，过滤@transient及null字段，拼装含?占位符的sql及参数列表，确保sql安全。
Java 中可以通过反射 + 自定义注解，结合实体类字段的元信息，动态拼装出符合 MySQL 语法的 INSERT 语句。核心思路是：定义注解标记表名、主键、忽略字段等；用反射读取类结构和注解；过滤非空/非忽略字段；组装 SQL 和参数占位符。
1. 定义自定义注解
先创建几个轻量级注解，用于描述实体与数据库的映射关系：
- @Table：标注在类上，指定对应表名；
- @Column：标注在字段上，指定列名、是否为主键、是否允许为空等；
- @Id（可选）：单独标注主键字段，简化判断；
- @Transient：标注不参与持久化的字段（如临时计算值）。
示例：
@Table("user")
public class User {
@Id
@Column(name = "id", primaryKey = true)
private Long id;
@Column(name = "username")
private String username;
@Column(name = "email")
private String email;
@Transient
private String tempField; // 不插入
}
2. 编写反射生成 SQL 的工具方法
核心逻辑包括：获取类上的 @Table 获取表名；遍历所有字段，跳过 @Transient 字段；检查字段值是否为 null（可按需跳过 null 值）；用 @Column.name 拼字段名，用 ? 占位参数。
关键点：
- 用
Field.setAccessible(true)访问私有字段； - 通过
field.get(obj)获取运行时值； - 建议只对非 null、非 transient、非主键（或主键允许插入时）的字段生成 INSERT 字段；
- 返回一个封装了 SQL 字符串和参数列表的对象（如
new InsertSql(sql, params)），便于后续 PreparedStatement 设置。
简化版实现片段：
public static InsertSql buildInsertSql(Object entity) throws Exception {
Class> clazz = entity.getClass();
Table table = clazz.getDeclaredAnnotation(Table.class);
if (table == null) throw new IllegalArgumentException("Missing @Table");
List<string> columns = new ArrayList();
List<object> values = new ArrayList();
String tableName = table.value();
for (Field field : clazz.getDeclaredFields()) {
field.setAccessible(true);
if (field.isAnnotationPresent(Transient.class)) continue;
Column column = field.getAnnotation(Column.class);
String columnName = column != null ? column.name() : field.getName();
Object value = field.get(entity);
// 可选：跳过 null 值（适用于 insert 忽略 null 字段的场景）
if (value == null && !column.allowNull()) continue;
columns.add(columnName);
values.add(value);
}
String sql = String.format("INSERT INTO %s (%s) VALUES (%s)",
tableName,
String.join(", ", columns),
String.join(", ", Collections.nCopies(columns.size(), "?"))
);
return new InsertSql(sql, values);
}</object></string>
3. 注意字段类型与 SQL 安全性
生成的 SQL 是带 ? 占位符的预编译语句模板，**不能直接拼接字符串值**（防 SQL 注入）。实际执行时应配合 PreparedStatement 使用：
<pre class="brush:php;toolbar:false;">InsertSql insertSql = SqlBuilder.buildInsertSql(user);
try (Connection conn = dataSource.getConnection();
PreparedStatement ps = conn.prepareStatement(insertSql.sql)) {
for (int i = 0; i
<p>另外注意：</p>
- 时间类型（
LocalDateTime 等）会被 JDBC 驱动自动转换，无需手动格式化； - 枚举类型建议统一转为字符串或整型（可通过自定义序列化逻辑处理）；
- 若字段含特殊字符（如 `-`、空格），需用反引号包裹列名：
`user-name`，可在拼接时加判断。
4. 进阶建议：支持批量插入与默认值
可扩展支持：
- 在
@Column中增加defaultValue = "CURRENT_TIMESTAMP"，生成 SQL 时跳过该字段，让数据库处理； - 提供
buildBatchInsertSql(List> entities)方法，复用单条逻辑，生成VALUES (?,?), (?,?)多组占位； - 结合 Lombok 的
@Getter减少样板代码； - 用
java.lang.reflect.Record（JDK 14+）简化不可变实体的反射访问。
不复杂但容易忽略的是：确保注解保留策略为 @Retention(RetentionPolicy.RUNTIME)，否则反射时拿不到。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
