学步园

  学习了一下Hibernate模拟，我们现在我们不用HIbernate的lib，自己来模拟一下hibernate工作过程，其实就是把java里面save()方法传进来的数据自己拼成SQL语句。再执行sql。

  那我们现在开始研究一下，首先我们把之前的项目复制一下，然后命名为Hibernate_0200_OR_Mapping_Simulation，首先来解释下OR Mapping吧，对象数据映射（ORM
ORM-Object/Relational Mapper，即“对象-关系型数据映射组件”。对于O/R，即 Object（对象）和 Relational（关系型数据），表示必须同时使用面向对象和关系型数据进行开发。 

  我们去掉其中的hibernate lib，去掉Teacher部分。我们现在要写自己的Session。创建Session类在里面建立save（）方法。

StudentTest.java

package com.tfj.test;

import com.tfj.hibernate.model.Student;

public class StudentTest {
	public static void main(String args[]) {
		Student s = new Student();
		s.setId(4);
		s.setName("s1");
		s.setAge(1);

		Session session = new Session();

		session.save(s);

	}
}

关于Session部分

package com.tfj.test;

import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

import com.tfj.hibernate.model.Student;

public class Session {
	String tableName = "student";
	Map<String, String> cfs = new HashMap<String, String>();
	String[] methodNames;

	public Session() {
		cfs.put("_id", "id");
		cfs.put("_name", "name");
		cfs.put("_age", "age");
		methodNames = new String[cfs.size()];
	}

	public void save(Student s) throws Exception {
		String sql = createSQL();

		Class.forName("com.mysql.jdbc.Driver");
		Connection conn = DriverManager.getConnection(
				"jdbc:mysql://localhost:3306/hibernate", "root", "111111");
		PreparedStatement ps = conn.prepareStatement(sql);
		for (int i = 0; i < methodNames.length; i++) {
			Method m = s.getClass().getMethod(methodNames[i]);
			Class r = m.getReturnType();
			if (r.getName().equals("java.lang.String")) {
				String returnValue = (String) m.invoke(s);
				ps.setString(i + 1, returnValue);
			}
			if (r.getName().equals("int")) {
				Integer returnValue = (Integer) m.invoke(s);
				ps.setInt(i + 1, returnValue);
			}
			System.out.println(m.getName() + "|" + r.getName());
		}

		ps.executeUpdate();

		ps.close();
		conn.close();

	}

	private String createSQL() {
		String str1 = "";
		String str2 = "";
		int index = 0;
		for (String s : cfs.keySet()) {

			String v = cfs.get(s);
			v = Character.toUpperCase(v.charAt(0)) + v.substring(1);
			methodNames[index] = "get" + v;
			str1 += s + ",";
			index++;
		}
		str1 = str1.substring(0, str1.length() - 1);
		System.out.println(str1);
		for (int i = 0; i < cfs.size(); i++) {
			str2 += "?,";
		}
		str2 = str2.substring(0, str2.length() - 1);
		System.out.println(str2);
		String sql = "insert into " + tableName + "(" + str1 + ")"
				+ " values (" + str2 + ")";
		System.out.println(sql);
		return sql;
	}
}

  我们来分析一下代码，在Session里有一个save()方法，那么我们先想到要构建出来sql语句，建立createSQL()方法。需要得到的sql语句是insert into student (_id,_name,_age) values (?,?,?);那么要把表和程序关联起来，想到用一个Map来存储，对应的键和值，键是数据库中表的键名，值是java中student属性名。

  下来就是得到_id,_name,_student，循环从map里拿到，再截取一下字符串，(得到?,?,?)同理。这样我们的sql就构造好了。

  然后是把得到的sql中的?,?,?替换掉，（要用到ps.setXXX(i+1,getXXX())）接下来我们遇到的问题就是，由于有各种数据类型，我们要确定就是数据类型和方法名。这里就用到了反射，通过s（s是一个student）拿到class再拿到方法。通过字符串组合就可以得到各种get方法（如getName()，getAge()，getId()），也是用反射拿到方法返回的数据类型来确定用setXXX()（如setString(i+1,getId())，setInt(i+1,getId())）。

  最后就是连接数据库，执行sql语句。来看一下插入成功的截图吧。