目录

一、ORM框架

1.1 什么是 ORM？       

1.2 反射在 ORM 中的角色

二、简化版 MyBatis：反射实现 ORM 核心逻辑

2.1 数据库实体类（与表映射）

2.2 数据库操作基础类（Dao）

2.3 反射核心：SqlSession类（模拟 MyBatis 的SqlSession）

2.4 测试类（Test）

2.5 运行结果

三、案例解析

3.1 类名与表名的映射

3.2 属性与字段的映射

3.3 动态 SQL 生成

3.4 解耦与扩展性

     在 Java 持久层框架中，MyBatis 作为经典的 ORM（Object-Relational Mapping，对象 - 关系映射）框架，让我们可以通过面向对象的方式操作数据库。而这一切的 “魔法”，离不开 Java 反射机制的支撑。本篇博客将结合简化版 MyBatis 案例，深入解析反射在 ORM 中的核心作用。

一、ORM框架

1.1 什么是 ORM？       

       ORM 的核心是 “对象 - 表映射”：将 Java 对象的属性与数据库表的字段一一对应，从而让开发者可以通过操作对象，间接完成对数据库的增删改查。简单来说，ORM框架的作用就是：

  • 将Java对象映射成数据库中的表（Java 对象Emps → 对应数据库表t_emps）

  • 将对象属性映射成数据库表的字段（对象属性ename → 对应表字段ename）

  • 将对象操作映射成SQL语句（调用emp.setEname("张三") → 等价于执行UPDATE t_emps SET ename='张三'...）

1.2 反射在 ORM 中的角色

        ORM 要实现 “对象→表” 的自动映射，必须在运行时动态获取对象的元数据（如类名、属性名、方法等），而这正是 Java 反射的核心能力：

  • 动态获取类名 → 推断数据库表名（如Emps → t_emps）。

  • 动态获取属性名 → 推断数据库字段名（如ename → ename）。

  • 动态调用 get/set 方法 → 读取 / 设置对象属性，进而生成 SQL 或封装查询结果。

二、简化版 MyBatis：反射实现 ORM 核心逻辑

下面通过一个简化案例，模拟 MyBatis 如何利用反射实现 “对象→SQL” 的自动转换。

2.1 数据库实体类（与表映射）

映射关系：Emps类 → 数据库表t_emps；类属性 → 表字段（如ename → ename）。

package com.demo1;

public class Emps {
	
	private int  eid;
	
	private String  ename;
	
	private String epwd;
	
	private String  ebirthday;
	
	private double  esalary;
	
	private String eaddress;
	
	private int  estate;

	public int getEid() {
		return eid;
	}

	public void setEid(int eid) {
		this.eid = eid;
	}

	public String getEname() {
		return ename;
	}

	public void setEname(String ename) {
		this.ename = ename;
	}

	public String getEpwd() {
		return epwd;
	}

	public void setEpwd(String epwd) {
		this.epwd = epwd;
	}

	public String getEbirthday() {
		return ebirthday;
	}

	public void setEbirthday(String ebirthday) {
		this.ebirthday = ebirthday;
	}

	public double getEsalary() {
		return esalary;
	}

	public void setEsalary(double esalary) {
		this.esalary = esalary;
	}

	public String getEaddress() {
		return eaddress;
	}

	public void setEaddress(String eaddress) {
		this.eaddress = eaddress;
	}

	public int getEstate() {
		return estate;
	}

	public void setEstate(int estate) {
		this.estate = estate;
	}

}

2.2 数据库操作基础类（Dao）

负责 JDBC 连接与 SQL 执行：

package com.demo1;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import com.mysql.cj.xdevapi.PreparableStatement;

public class Dao {

	Connection conn;

	public Dao() {

		try {
			
			Class.forName("com.mysql.cj.jdbc.Driver");

			conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jk202508", "root", "152602");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	public void closeDB() {

		if (null != conn) {
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

	}

	public void addData(String sql) {
		try {
			PreparedStatement pstmt = conn.prepareStatement(sql);

			pstmt.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			this.closeDB();
		}
	}

}

2.3 反射核心：SqlSession类（模拟 MyBatis 的SqlSession）

通过反射自动生成 INSERT SQL，并执行：

反射关键操作：

  • Class对象.getSimpleName()：获取类名（如Emps）。

  • Class对象.getDeclaredMethods()：获取所有方法（包括私有方法）。

  • method.invoke(obj)：调用对象的方法，动态获取属性值。

package com.demo1;

import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.List;

public class SqlSession {

	/**
     * 自动生成INSERT SQL并执行
     * 参数为obj： 要插入的Java对象
     */
	public void addObject(Object obj) throws Exception {

		// 核心的就是：反射
		String sql = "insert into ";

		// 获取表名，通过类名去获取 假设所有表明都以"t_"开头
		Class c = obj.getClass();
		String className = c.getSimpleName();

		System.out.println(className);

		sql += "t_" + className.toLowerCase() + "(";
//		System.out.println(sql);

		// 声明一个集合放入列名
		List<String> columns = new ArrayList<String>();

		// 声明一个集合,存放数据库表中的值
		List<Object> values = new ArrayList<Object>();

		// 获取列名,通过反射获取get方法，get方法可以获取列名，可以获取值
		Method[] ms = c.getDeclaredMethods();

		for (Method m : ms) {

			String methodName = m.getName();
//			System.out.println("所有的方法名为： " + methodName);

			if (methodName.startsWith("get")) {
//				System.out.println("方法名为： " + methodName);

				String columnName = methodName.substring(3).toLowerCase();

				// 假设id是自增长的，不需要去设置
				if (!columnName.contains("id")) {

					System.out.println(columnName);
					columns.add(columnName); // 把列名放入集合中

					Object abjValue = m.invoke(obj, null);    // 调用getter方法获取属性值

					if (abjValue instanceof String) {
						values.add("'" + abjValue + "'"); // 把值放入集合中
					}else {
						values.add(abjValue);
					}

				}
			}

		}

		// 把列名拼进sql
		for (int i = 0; i < columns.size(); i++) {
			if (i == columns.size() - 1) {
				sql += columns.get(i) + ")";
			} else {
				sql += columns.get(i) + ",";
			}
		}

		sql += " values(";

		// 把值拼进sql
		for (int i = 0; i < values.size(); i++) {
			if (i == values.size() - 1) {
				sql += values.get(i) + ")";
			} else {
				sql += values.get(i) + ",";
			}
		}
		
		System.out.println(sql);
		
		// 将sql语句传给Dao类去执行
		Dao dao = new Dao();
		dao.addData(sql);

	}

}

2.4 测试类（Test）

package com.demo1;

public class Test {

	public static void main(String[] args) {
		
		Emps emp = new Emps();
		emp.setEname("花花");
		emp.setEpwd("123456");
		emp.setEbirthday("2004-9-9");
		emp.setEaddress("成都");
		emp.setEsalary(10000.90);
		emp.setEstate(1);
		
		// 一个对象和数据库的一张表对应
		SqlSession sqlSession = new SqlSession();
		try {
			sqlSession.addObject(emp);
			System.out.println("插入成功！");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
}

2.5 运行结果

三、案例解析

3.1 类名与表名的映射

        通过Class对象.getSimpleName()获取类名（如Emps），再约定 “表名 = t_ + 类名小写”，实现类→表的自动映射。

3.2 属性与字段的映射

        通过反射遍历所有get方法：

  • 方法名getEname → 截取后得到字段名ename。

  • 调用getEname() → 动态获取属性值“花花”。

从而实现属性→字段的自动映射。

3.3 动态 SQL 生成

        基于反射收集的 “字段名” 和 “属性值”，自动拼接出完整的insert语句：

insert into t_emps(epwd,ename,esalary,eaddress,estate,ebirthday) values('123456','花花',10000.9,'成都',1,'2004-9-9')

3.4 解耦与扩展性

        如果新增一个Stus类（对应t_stus表），无需修改SqlSession代码，直接调用sqlSession.addObject(s)即可，体现了 ORM“配置化、可扩展” 的核心优势 —— 这一切都依赖反射的 “动态性”。

Stus类：

package com.demo1;

public class Stus {

	private int sid;

	private String sname;

	private String saddress;

	public int getSid() {
		return sid;
	}

//	public void setSid(int sid) {
//		this.sid = sid;
//	}

	public String getSname() {
		return sname;
	}

	public void setSname(String sname) {
		this.sname = sname;
	}

	public String getSaddress() {
		return saddress;
	}

	public void setSaddress(String saddress) {
		this.saddress = saddress;
	}

}

Test类：

package com.demo1;

public class Test {

	public static void main(String[] args) {
		
		Stus s = new Stus();
		s.setSname("QQ");
		s.setSaddress("南京");
		
		Emps emp = new Emps();
		emp.setEname("花花");
		emp.setEpwd("123456");
		emp.setEbirthday("2004-9-9");
		emp.setEaddress("成都");
		emp.setEsalary(10000.90);
		emp.setEstate(1);
		
		// 一个对象和数据库的一张表对应
		SqlSession sqlSession = new SqlSession();
		try {
			sqlSession.addObject(s);
//			sqlSession.addObject(emp);
			System.out.println("插入成功！");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}
	
}

# java # mybatis # 开发语言
Logo
AI Agent技术社区

Agent 垂直技术社区，欢迎活跃、内容共建。

更多推荐

SeedVR2终极指南：如何用单步扩散模型实现专业级视频修复

还在为老旧视频的模糊画质而烦恼吗？面对抖动严重的监控录像或褪色的家庭影像，你是否曾希望有一种简单高效的修复方案？SeedVR2正是为解决这些痛点而生的一站式视频修复工具。作为字节跳动推出的先进视频修复模型，它能够在单步推理中实现专业级的视频质量提升，彻底改变了传统视频修复的工作流程。## 核心价值：为什么选择SeedVR2进行视频修复？**传统视频修复的三大瓶颈**：1. **计算成本高

avatar AI Agent技术社区

深度解析Amlogic S9xxx电视盒子Armbian系统：从闲置设备到Linux服务器的终极实战指南

你是否拥有一台闲置的Amlogic S9xxx系列电视盒子？想让它摆脱单一的视频播放功能，变身为功能强大的Linux服务器、开发平台或家庭媒体中心？本指南将为你详细解析如何通过Armbian系统实现这一转变，让你的电视盒子重获新生，成为高性能的Linux设备。Armbian系统基于Debian/Ubuntu构建，专为ARM芯片优化，提供了完整的Linux生态支持。## 🎯 核心价值与独特优势

avatar AI Agent技术社区

CANN/runtime Event管理API

本章节描述 CANN Runtime 的 Event 管理接口，用于事件的创建、记录、同步、计时及 IPC 跨进程共享。- [`aclError aclrtCreateEvent(aclrtEvent *event)`](#aclrtCreateEvent)：创建Event，创建出来的Event可用于统计两个Event之间的耗时、多Stream之间的任务同步等场景。- [`aclError

avatar AI Agent技术社区