java实体类代码,java实体类转实体类

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

如何通过java反射将数据库表生成实体类

首先有几点声明：

1、代码是在别人的基础进行改写的；

2、大家有什么改进的意见可以告诉我，也可以自己改好共享给其他人；

3、刚刚毕业，水平有限，肯定有许多不足之处；

4、希望刚刚学习java的同学能有所启发。

//这个是做转换的类，里面的DB只是封装了数据库的连接，大家可以用自己的，随意

package com.tt.util.gen.entity.tool;

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.io.InputStream;

import java.io.PrintWriter;

import java.sql.Connection;

import java.sql.DatabaseMetaData;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.Properties;

import com.tt.util.DB;

public class GenEntityMysql {

private String packageOutPath;// 指定实体生成所在包的路径

private String authorName;// 作者名字

private String tablename;// 表名

private String databasename;// 数据库名

private ListString tablenames;// 拿到对应数据库中所有的实体类（实体类需要与其他表明做区分）

private ListString colnames; // 列名集合

private ListString colTypes; // 列名类型集合

private boolean f_util = false; // 是否需要导入包java.util.*

private boolean f_sql = false; // 是否需要导入包java.sql.*

* 构造函数

public GenEntityMysql() {

// 使用properties读取配置文件

Properties prop = new Properties();

try {

InputStream genentity = getClass().getResourceAsStream(

"/genentity.properties");

prop.load(genentity);

if (genentity != null) {

genentity.close();

}

} catch (Exception e) {

System.out.println("file " + "catalogPath.properties"

+ " not found!\n" + e);

}

this.databasename = prop.getProperty("databasename").toString();

this.tablename = prop.getProperty("tablename").toString();

this.packageOutPath = prop.getProperty("packageOutPath").toString();

this.authorName = prop.getProperty("authorName").toString();

}

// 创建多个实体类

private void genEntity(ListString tablenames, Connection conn) {

// 使用第归生成文件

for (String tablename : tablenames) {

this.genEntity(tablename, conn);

}

// 创建单个实体类

private void genEntity(String tablename, Connection conn) {

String sql = "select * from " + tablename;

PreparedStatement pstmt = null;

ResultSetMetaData rsmd = null;

try {

pstmt = DB.getPStmt(conn, sql);

rsmd = pstmt.getMetaData();

int size = rsmd.getColumnCount(); // 统计列

colnames = new ArrayListString();

colTypes = new ArrayListString();

for (int i = 0; i size; i++) {

colnames.add(rsmd.getColumnName(i + 1));

colTypes.add(rsmd.getColumnTypeName(i + 1));

if (colTypes.get(i).equalsIgnoreCase("datetime")) {

f_util = true;

}

if (colTypes.get(i).equalsIgnoreCase("image")

|| colTypes.get(i).equalsIgnoreCase("text")) {

f_sql = true;

}

System.out.println(colnames);

System.out.println(colTypes);

} catch (SQLException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

} finally {

DB.close(pstmt);

}

// 在内存中生成代码

String content = parse(tablename);

// 写入到文件中

try {

File directory = new File("");

String outputPath = directory.getAbsolutePath() + "/src/"

+ this.packageOutPath.replace(".", "/") + "/";

System.out.println("写出的路径:" + outputPath);

// 检测路径是否存在，不存在就创建路径

File path = new File(outputPath);

if (!path.exists() !path.isDirectory()) {

path.mkdir();

System.out.println(path.exists());

}

// 创建文件

outputPath += initcap(tablename) + ".java";

File file = new File(outputPath);

if (!file.exists()) {

file.createNewFile();

}

// 写出到硬盘

FileWriter fw = new FileWriter(file);

PrintWriter pw = new PrintWriter(fw);

pw.println(content);

pw.flush();

pw.close();

} catch (IOException e) {

e.printStackTrace();

}

private void getAllEntityTable(Connection conn, ListString tablenames) {

ResultSet rs = null;

try {

DatabaseMetaData dmd = (DatabaseMetaData) conn.getMetaData();

* TABLE_CAT String = 表类别（可为 null）

* TABLE_SCHEM String = 表模式（可为null）

* TABLE_NAME String = 表名称

* TABLE_TYPE String = 表类型

rs = dmd.getTables(null, null, "%", null);

while (rs.next()) {

tablenames.add(rs.getString("TABLE_NAME"));

}

} catch (SQLException e) {

e.printStackTrace();

} finally {

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

/**

* @param tablename

* @return

private String parse(String tablename) {

StringBuffer sb = new StringBuffer();

// 判断是否导入工具包

if (f_util) {

sb.append("import java.util.Date;\r\n");

}

if (f_sql) {

sb.append("import java.sql.*;\r\n");

}

sb.append("package " + this.packageOutPath + ";\r\n");

sb.append("\r\n");

// 注释部分

sb.append(" /**\r\n");

sb.append(" * " + tablename + " 实体类\r\n");

sb.append(" * " + new Date() + " " + this.authorName + "\r\n");

sb.append(" */ \r\n");

// 实体部分

sb.append("\r\n\r\npublic class " + initcap(tablename) + "{\r\n");

processAllAttrs(sb);// 属性

processAllMethod(sb);// get set方法

sb.append("}\r\n");

return sb.toString();

}

/**

* 功能：生成所有属性

* @param sb

private void processAllAttrs(StringBuffer sb) {

for (int i = 0; i colnames.size(); i++) {

sb.append("\tprivate " + sqlType2JavaType(colTypes.get(i)) + " "

+ colnames.get(i) + ";\r\n");

}

/**

* 功能：生成所有方法

* @param sb

private void processAllMethod(StringBuffer sb) {

for (int i = 0; i colnames.size(); i++) {

sb.append("\tpublic void set" + initcap(colnames.get(i)) + "("

+ sqlType2JavaType(colTypes.get(i)) + " " + colnames.get(i)

+ "){\r\n");

sb.append("\t\tthis." + colnames.get(i) + "=" + colnames.get(i)

+ ";\r\n");

sb.append("\t}\r\n");

sb.append("\tpublic " + sqlType2JavaType(colTypes.get(i)) + " get"

+ initcap(colnames.get(i)) + "(){\r\n");

sb.append("\t\treturn " + colnames.get(i) + ";\r\n");

sb.append("\t}\r\n");

}

/**

* 功能：将输入字符串的首字母改成大写

* @param str

* @return

private String initcap(String str) {

char[] ch = str.toCharArray();

if (ch[0] = 'a' ch[0] = 'z') {

ch[0] = (char) (ch[0] - 32);

}

return new String(ch);

}

/**

* 功能：获得列的数据类型

* @param sqlType

* @return

private String sqlType2JavaType(String sqlType) {

if (sqlType.equalsIgnoreCase("bit")) {

return "boolean";

} else if (sqlType.equalsIgnoreCase("tinyint")) {

return "byte";

} else if (sqlType.equalsIgnoreCase("smallint")) {

return "short";

} else if (sqlType.equalsIgnoreCase("int")) {

return "int";

} else if (sqlType.equalsIgnoreCase("bigint")) {

return "long";

} else if (sqlType.equalsIgnoreCase("float")) {

return "float";

} else if (sqlType.equalsIgnoreCase("decimal")

|| sqlType.equalsIgnoreCase("numeric")

|| sqlType.equalsIgnoreCase("real")

|| sqlType.equalsIgnoreCase("money")

|| sqlType.equalsIgnoreCase("smallmoney")) {

return "double";

} else if (sqlType.equalsIgnoreCase("varchar")

|| sqlType.equalsIgnoreCase("char")

|| sqlType.equalsIgnoreCase("nvarchar")

|| sqlType.equalsIgnoreCase("nchar")

|| sqlType.equalsIgnoreCase("text")) {

return "String";

} else if (sqlType.equalsIgnoreCase("datetime")) {

return "Date";

} else if (sqlType.equalsIgnoreCase("image")) {

return "Blod";

}

return null;

}

/**

* 出口 TODO

* @param args

public static void main(String[] args) {

new GenEntityMysql().start();

}

private void start() {

// 创建连接

Connection conn = DB.getConn();

if (databasename != null !databasename.equals("")

tablename != null !tablename.equals("")) {

System.out.println("databasename 和 tablename 不能同时存在");

} else {

// 如果配置文件中有数据库名字，则可以拿到其中所有的实体类

if (databasename != null !databasename.equals("")) {

// 获取所有实体表名字

tablenames = new ArrayListString();

getAllEntityTable(conn, tablenames);

System.out.println(tablenames);

// 为每个实体表生成实体类

genEntity(tablenames, conn);

} else {

// 为指定实体表生成实体类

genEntity(tablename, conn);

}

// 关闭数据库连接

if (conn != null) {

DB.close(conn);

}

相关问答

Q1: JAVA如何设计实体类？

实体类，只要里面包含属性跟方法就可以了，例如public class demo{

private int age;

private String name;

}。这就是一个标准的实体类

Q2: java比较实体类

这种情况你可以使用反射去写一个通用的方法，不过前提是你的那些实体类都是简单的包装类，稍后奉上代码。代码如下：

package pojo;

/**

* Created by liaokai on 2017/11/17 0017.

public class Person {

private String name;

private int age;

public Person(String name, int age) {

this.name = name;

this.age = age;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public int getAge() {

return age;

}

public void setAge(int age) {

this.age = age;

}

@Override

public boolean equals(Object o) {

if (this == o) return true;

if (o == null || getClass() != o.getClass()) return false;

Person person = (Person) o;

if (age != person.age) return false;

return name != null ? name.equals(person.name) : person.name == null;

}

@Override

public int hashCode() {

int result = name != null ? name.hashCode() : 0;

result = 31 * result + age;

return result;

}

@Override

public String toString() {

return "Person{" +

"name='" + name + '\'' +

", age=" + age +

'}';

}

package util;

import pojo.Person;

import java.lang.reflect.Field;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

/**

* Created by liaokai on 2017/11/17 0017.

public class CompareUtilT {

public ListMap compareT(T t1,T t2,String className){

ListMap list = new ArrayListMap();

//内容没改变直接返回

if(t1.equals(t2)){

return list;

}

try {

Class c = Class.forName(className);

//读取t1和t2中的所有属性

Field[] fields = c.getDeclaredFields();

for (int i = 0; i fields.length; i++) {

Field field =fields[i];

field.setAccessible(true);

Object value1=field.get(t1);

Object value2=field.get(t2);

//判断这两个值是否相等

if(!isValueEquals(value1,value2)){

Map map = new HashMap();

map.put("name",field.getName());

map.put("before",value1);

map.put("after",value2);

list.add(map);

}

} catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (IllegalAccessException e) {

e.printStackTrace();

}

return list;

}

private boolean isValueEquals(Object value1, Object value2) {

if(value1==nullvalue2==null){

return true;

}

if(value1==nullvalue2!=null){

return false;

}

if(value1.equals(value2)){

return true;

}

return false;

}

package pojo;

import util.CompareUtil;

/**

* Created by liaokai on 2017/11/17 0017.

public class Test {

public static void main(String[] args) {

Person p1 = new Person("张三",14);

Person p2 = new Person("张三",15);

Person p3 = new Person("李四",15);

CompareUtilPerson compareUtil = new CompareUtilPerson();

System.out.println(compareUtil.compareT(p1,p1,Person.class.getName()));

System.out.println(compareUtil.compareT(p1,p2,Person.class.getName()));

System.out.println(compareUtil.compareT(p1,p3,Person.class.getName()));

System.out.println(compareUtil.compareT(p2,p3,Person.class.getName()));

}

//运行结果

[]

[{before=14, name=age, after=15}]

[{before=张三, name=name, after=李四}, {before=14, name=age, after=15}]

[{before=张三, name=name, after=李四}]

Q3: java里面实体类和dao类有一段实例，希望各位高手给注释一下要详细的注释，字数有限就不想实体类了

package s2jsp.bysj.dao; //此类所在包的名称

import java.sql.Connection; //导入Connection类

import java.sql.PreparedStatement; //导入PreparedStatement类

import java.sql.ResultSet; //导入ResultSet类

import java.util.ArrayList; //导入ArrayList类

import java.util.List; //导入List类

import s2jsp.bysj.entity.Users; //导入Users实体类

public class UserDao extends BaseDao { //UserDao类继承了BaseDao类

private Connection conn; //声明私有变量：Connection对象

private PreparedStatement pstmt; //声明私有变量：PreparedStatement对象

private ResultSet rs; //声明私有变量：ResultSet数据集对象

/**

* 根据用户名和密码，查找相关用户信息

* @return Users类的对象：用户对象

*@userName 用户名

*@password 用户密码

public Users findUsers(String userName, String password) {

Users user = null; //声明实体类Users对象

String sql = "select * from users where userName=? and password=? "; //定义sql变量，此变量用来代替执行的SQL语句

try { //将会发生异常的代码放在了try{}catch{}块中

conn = this.getConn(); //初始化了Connection对象：conn，getConn()方法是继承自BaseDao的方法

pstmt = conn.prepareStatement(sql); //初始化PreparedStatement对象：pstmt

pstmt.setString(1, userName); //为SQL语句中的参数1设置值

pstmt.setString(2, password); //为SQL语句中的参数2设置值

rs = pstmt.executeQuery(); //用PreparedStatement的对象的executeQuery()方法初始化ResultSet对象：rs

if (rs.next()) { //如果ResultSet的next()方法返回true，则说明目标数据库中的下一行有数据

user = new Users(); //初始化Users实体类，此类准备用来初始化其域

user.setUserID(rs.getInt("userID")); //用数据库中的值初始化Users实体类中的UserID字段

user.setUserName(userName); //用数据库中的值初始化Users实体类中的UserName字段

user.setPassword(password); //用数据库中的值初始化Users实体类中的Password字段

user.setStatus(rs.getInt("status")); //用数据库中的值初始化Users实体类中的Status字段

}

} catch (Exception e) { //catch内使用了Exception异常根类的printStackTrace()方法：表示将错误信息打印在堆栈上

e.printStackTrace();

} finally { //finally块中的语句表示始终要执行的语句，并且在try语句块后执行

this.closeAll(conn, pstmt, rs); //try语句块中执行完毕或发生异常则使用closeAll()关闭所有使用到的数据库连接对象，此处省略this也可以，conn是Connection对象，pstmt是PreparedStatement对象，rs是ResultSet对象

}

return user; //此方法最后返回Users实体类的对象，注：如果方法定义有返回值则一定要加此关键字

}

/**

* 判断数据库中当前用户名是否存在

* @param userName 用户名

* @return 存在返回true,否则返回false

public boolean findUsers(String userName){ //此方法用来查找传入的用户是否存在，返回一个布尔类型的值，true表示存在，false表示不存在

String sql = "select * from users where userName=? "; //定义SQL语句并放入sql变量中，这样的好处是简化了代码的长度和复用的便利

try {

conn = this.getConn(); //用BaseDao类的getConn()方法初始化Connection对象：conn

pstmt = conn.prepareStatement(sql); //用Connection对象的prepareStatement()方法初始化PreparedStatement对象：pstmt

pstmt.setString(1, userName); //设置SQL语句参数1的值：userName

rs = pstmt.executeQuery(); //使用PreparedStatement对象的executeQuery()方法初始化ResultSet对象：rs

if (rs.next()) { //如果数据库中有记录则返回true，此时方法停止

return true;

}

} catch (Exception e) {

e.printStackTrace(); //将错误信息打印到控制台

} finally {

this.closeAll(conn, pstmt, rs); //关闭所有使用到的数据库连接对象，此处可省略this关键字

}

return false; //最后的返回值可以是任意布尔类型的值

}

/**

* 添加用户信息

* @param userName

* @param password

* @return 操作数据库影响行数

public int insertUser(String userName, String password,int status) { //插入一个用户的方法，此方法类的参数跟数据库中强制不为空的列是一一对应的

String sql = "insert into users values(?,?,?) "; //定义SQL语句

String[] params = new String[] { userName, password ,status+""}; //定义字符串数组用来存放传入的参数，因为传入的参数可能不止一个所以定义一个字符串数组来存放，困了余下的代码都差不多所以我简单写了

return this.executeSQL(sql, params);

}

/**

* 查找所有的注册用户信息

* @return 用户列表

public List selectAllUser(){

List list=new ArrayList(); //实例化一个ArrayList对象，因为ArrayList是List对象的子类

String sql = "select * from users ";

try {

conn = this.getConn();

pstmt = conn.prepareStatement(sql);

rs = pstmt.executeQuery();

while(rs.next()) {

Users user = new Users();

user.setUserID(rs.getInt("userID"));

user.setUserName(rs.getString("userName"));

user.setPassword(rs.getString("password"));

user.setStatus(rs.getInt("status"));

list.add(user);

}

} catch (Exception e) {

e.printStackTrace();

} finally {

this.closeAll(conn, pstmt, rs);

}

return list; //此方法返回一个List对象

}

/**

* 根据用户ID,进行删除操作

* @param userID

* @return 执行SQL语句所影响的数据库行数

public int deleteUserByID(String userID){

String sql="delete from users where userID = ? "; //?号表示占位符号此处要用一个变量表示

String[] param = new String[]{ userID };

return this.executeSQL(sql, param);

}

//PreaparedStatement和Statement比较而言，PreparedStatement更适合于做修改插入的操作，应为此类是预编译的类，他的执行效率要高于Statement类。而普通的查询则使用Statement就可以了。

//ResultSet是结果集的意思，他用来存放从数据库中读取到的所有数据，他用next()方法来确定下一行是否还有数据，用返回的布尔类型值类表示。使用ResultSet对象的getXX(index)方法获取程序从数据库中读取到的值，index为参数位置，从1开始，1对应数据中第一个字段。

//Connection是连接的意思，他的PreparedStatement和createStatement分别用来初始化PreaparedStatement对象和Statement对象。为SQL语句中的参数赋值用PreparedStatement对象的setXX(index,值)方法，参数位置从1开始递增。

//List是一个接口，ArrayList是实现了List接口的类，也可以其为List的子类，所以List lst=new ArrayList();是一种编译时多态的表现，是完全允许的。其返回的是ArrayList子类的对象。ArrayList一般用来对数据的遍历查询，而LinkedList则比较擅长于增删改，他们都是集合，在此处用来存放实体类的对象。

//try{}catch{}finally{}就不用我多说了吧！用来捕捉容易发生异常的代码段，一些抛出异常的类是要求强制捕捉的，如果不捕捉编辑器会报告一个错误。finally{}块中的代码是无论代码执行正确与否则都会执行，此处用来对数据库连接对象执行关闭操作。

//其实我也是一个初学者，说了这么多也许还有很多没说到的地方，当然这段代码如果要解释完全是要牵扯到很多Java知识，应为篇幅和个人精力和知识量有限，先说到这儿了，各位也请多多包涵，多多指正吧！

Q4: 谁能帮我写下java实体类

@Entity

@Table(name = "t_book")

public class Book implements Serializable{

private static final long serialVersionUID = -2738902322135434977L;

@GenericGenerator(name = "generator", strategy = "uuid")

@Id

@GeneratedValue(generator = "generator")

@Column(name = "uuid", unique = true, nullable = false, length = 32)

private String uuid;