利用JAVA反射,读取数据库表名,自动生成对应实体类的操作

本代码是利用java反射,读取数据库表自动根据表名生成实体类,数据库采用老牌SQLSERVER 2000,驱动为JTDS,其他数据库可根据情况自定修改。

代码中包含了大部分数据库类型与JAVA类型的转换,少数未包含进去的会在生成代码时打印出来,方面后期查找修改。

import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 从数据库表反射出实体类,自动生成实体类
 *
 * @author Zero
 *
 */
public class SqlHelper {
	//基本数据配置
	private String packageOutPath = "com.xxx.entity.system";// 指定实体生成所在包的路径
	private String authorName = "Zero";// 作者名字
	private String tablename = "xxx";// 表名
	private String[] colnames; // 列名数组
	private String[] colTypes; // 列名类型数组
	private String version = "V0.01"; // 版本
	private int[] colSizes; // 列名大小数组
	private boolean f_util = false; // 是否需要导入包java.util.*
	private boolean f_sql = false; // 是否需要导入包java.sql.*
	private boolean f_lang = false; // 是否需要导入包java.sql.*
	private String defaultPath = "/src/main/java/";
	// 数据库连接
	private static final String URL = "jdbc:jtds:sqlserver://192.168.29.128:1433/xxx";
	private static final String NAME = "sa";
	private static final String PASS = "xxx";
	private static final String DRIVER = "net.sourceforge.jtds.jdbc.Driver";

	/*
	 * 构造函数
	 */
	public SqlHelper() {
		// 创建连接
		Connection con;
		// 查要生成实体类的表
		String sql = "select * from " + tablename;
		PreparedStatement pStemt = null;
		try {
			try {
				Class.forName(DRIVER);
			} catch (ClassNotFoundException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			con = DriverManager.getConnection(URL, NAME, PASS);
			pStemt = con.prepareStatement(sql);
			ResultSetMetaData rsmd = pStemt.getMetaData();
			int size = rsmd.getColumnCount(); // 统计列
			colnames = new String[size];
			colTypes = new String[size];
			colSizes = new int[size];
			for (int i = 0; i < size; i++) {

				colnames[i] = rsmd.getColumnName(i + 1);
				colTypes[i] = rsmd.getColumnTypeName(i + 1);
				//自动生成包配置

				// if (colTypes[i].equalsIgnoreCase("datetime")) {
				// f_util = true;
				// }
				if (colTypes[i].equalsIgnoreCase("image") || colTypes[i].equalsIgnoreCase("text")
						|| colTypes[i].equalsIgnoreCase("datetime") || colTypes[i].equalsIgnoreCase("time")
						|| colTypes[i].equalsIgnoreCase("date") || colTypes[i].equalsIgnoreCase("datetime2")) {
					f_sql = true;
				}
				// if (colTypes[i].equalsIgnoreCase("int")) {
				// f_lang = true;
				// }
				colSizes[i] = rsmd.getColumnDisplaySize(i + 1);
			}

			String content = parse(colnames, colTypes, colSizes);

			try {
				File directory = new File("");

				String path = this.getClass().getResource("").getPath();

				System.out.println(path);

				String outputPath = directory.getAbsolutePath() + this.defaultPath
						+ this.packageOutPath.replace(".", "/") + "/" + initcap(tablename) + ".java";
				System.out.println("执行完毕,生成路径为:"+outputPath);
				FileWriter fw = new FileWriter(outputPath);
				PrintWriter pw = new PrintWriter(fw);
				pw.println(content);
				pw.flush();
				pw.close();
			} catch (IOException e) {
				e.printStackTrace();
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {

		}
	}

	/**
	 * 功能:生成实体类主体代码
	 *
	 * @param colnames
	 * @param colTypes
	 * @param colSizes
	 * @return
	 */
	private String parse(String[] colnames, String[] colTypes, int[] colSizes) {
		StringBuffer sb = new StringBuffer();
		// 生成package包路径
		sb.append("package " + this.packageOutPath + ";\r\n");
		// 判断是否导入工具包
		if (f_util) {
			sb.append("import java.util.Date;\r\n");
		}
		if (f_sql) {
			sb.append("import java.sql.*;\r\n");
		}
		if (f_lang) {
			sb.append("import java.lang.*;\r\n");
		}

		sb.append("\r\n");
		// 注释部分
		sb.append("  /**\r\n");
		sb.append("  * @文件名称:" + this.tablename + ".java\r\n");
		sb.append("  * @创建时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "\r\n");
		sb.append("  * @创 建 人:" + this.authorName + " \r\n");
		sb.append("  * @文件描述:" + tablename + " 实体类\r\n");
		sb.append("  * @文件版本:" + this.version + " \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");

		// System.out.println(sb.toString());
		return sb.toString();
	}

	/**
	 * 功能:生成所有属性
	 *
	 * @param sb
	 */
	private void processAllAttrs(StringBuffer sb) {

		for (int i = 0; i < colnames.length; i++) {
			sb.append("\tprivate " + sqlType2JavaType(colTypes[i]) + " " + colnames[i] + ";\r\n");
		}
	}

	/**
	 * 功能:生成所有方法
	 *
	 * @param sb
	 */
	private void processAllMethod(StringBuffer sb) {

		for (int i = 0; i < colnames.length; i++) {
			sb.append("\tpublic void set" + initcap(colnames[i]) + "(" + sqlType2JavaType(colTypes[i]) + " "
					+ colnames[i] + "){\r\n");
			sb.append("\tthis." + colnames[i] + "=" + colnames[i] + ";\r\n");
			sb.append("\t}\r\n");
			sb.append("\tpublic " + sqlType2JavaType(colTypes[i]) + " get" + initcap(colnames[i]) + "(){\r\n");
			sb.append("\t\treturn " + colnames[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("decimal") || sqlType.equalsIgnoreCase("money")
				|| sqlType.equalsIgnoreCase("smallmoney") || sqlType.equalsIgnoreCase("numeric")
				|| sqlType.equalsIgnoreCase("bigint")) {
			return "Long";
		} else if (sqlType.equalsIgnoreCase("float")) {
			return "Double";
		} else if (sqlType.equalsIgnoreCase("int") || sqlType.equalsIgnoreCase("int identity")) {
			return "Integer";
		} else if (sqlType.equalsIgnoreCase("image") || sqlType.equalsIgnoreCase("varbinary(max)")
				|| sqlType.equalsIgnoreCase("varbinary") || sqlType.equalsIgnoreCase("udt")
				|| sqlType.equalsIgnoreCase("timestamp") || sqlType.equalsIgnoreCase("binary")) {
			return "Byte[]";
		} else if (sqlType.equalsIgnoreCase("nchar") || sqlType.equalsIgnoreCase("nvarchar(max)")
				|| sqlType.equalsIgnoreCase("nvarchar") || sqlType.equalsIgnoreCase("nvarchar(ntext)")
				|| sqlType.equalsIgnoreCase("uniqueidentifier") || sqlType.equalsIgnoreCase("xml")
				|| sqlType.equalsIgnoreCase("char") || sqlType.equalsIgnoreCase("varchar(max)")
				|| sqlType.equalsIgnoreCase("text") || sqlType.equalsIgnoreCase("varchar")) {
			return "String";
		} else if (sqlType.equalsIgnoreCase("real")) {
			return "Float";
		} else if (sqlType.equalsIgnoreCase("smallint") || sqlType.equalsIgnoreCase("tinyint")) {
			return "Short";
		} else if (sqlType.equalsIgnoreCase("date") || sqlType.equalsIgnoreCase("datetime")
				|| sqlType.equalsIgnoreCase("time") || sqlType.equalsIgnoreCase("datetime2")) {
			return "Date";
		} else {
			System.out.println("数据类型异常,类型为:" + sqlType);
		}

		return null;
	}

	/**
	 * 出口 TODO
	 *
	 * @param args
	 */
	public static void main(String[] args) {

		new SqlHelper();

	}
}

补充知识:java通过反射获取类名、属性名称以及@Table注解上的表名称

我就废话不多说了,大家还是直接看代码吧~

import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @author caizw
 * @createDate 2018/2/8
 * @description 反射工具类
 */
public class ReflectUtils {

  /**
   * 获取实体类主键
   *
   * @param clazz
   * @return
   */
  public static Field getIdField(Class<?> clazz) {
    Field[] fields = clazz.getDeclaredFields();
    Field item = null;
    for (Field field : fields) {
      Id id = field.getAnnotation(Id.class);
      if (id != null) {
        field.setAccessible(true);
        item = field;
        break;
      }
    }
    if (item == null) {
      Class<?> superclass = clazz.getSuperclass();
      if (superclass != null) {
        item = getIdField(superclass);
      }
    }
    return item;
  }

  /**
   * 根据主键名称获取实体类主键属性值
   *
   * @param clazz
   * @param pkName
   * @return
   */
  public static Object getPkValueByName(Object clazz, String pkName) {
    try {
      String firstLetter = pkName.substring(0, 1).toUpperCase();
      String getter = "get" + firstLetter + pkName.substring(1);
      Method method = clazz.getClass().getMethod(getter, new Class[]{});
      Object value = method.invoke(clazz, new Object[]{});
      return value;
    } catch (Exception e) {
      return null;
    }
  }

  /**
   * 通过反射将 class1不为空的值赋值给class2
   *
   * @param class1
   * @param class2
   * @throws Exception
   */
  public static void reflectClass1ToClass2(Object class1, Object class2) throws Exception {
    Field[] field = class1.getClass().getDeclaredFields();
    for (int i = 0; i < field.length; i++) {
      String name = field[i].getName();
      if ("serialVersionUID".equals(name)) {
        continue;
      }
      name = name.substring(0, 1).toUpperCase() + name.substring(1);
      Method m1 = class1.getClass().getMethod("get" + name);
      Object value = m1.invoke(class1);
      if (value != null) {
        Field f = field[i];
        f.setAccessible(true);
        f.set(class2, value);
      }
    }
  }

  /**
   * 获取实体类 @Column 的其中一个属性名称
   *
   * @param clazz
   * @return
   */
  public static Map<String, String> getColumnName(Class<?> clazz) {
    Map<String, String> map = new ConcurrentHashMap<>();
    Field[] fields = clazz.getDeclaredFields();
    for (Field field : fields) {
      if (field.isAnnotationPresent(Column.class)) {
        /**
         * 获取字段名
         */
        Column declaredAnnotation = field.getDeclaredAnnotation(Column.class);
        String column = declaredAnnotation.name();
        map.put("fieldNames", field.getName());
        map.put("column", column);
        break;
      }
    }
    return map;
  }

  /**
   * 通过获取类上的@Table注解获取表名称
   *
   * @param clazz
   * @return
   */
  public static Map<String, String> getTableName(Class<?> clazz) {
    Map<String, String> map = new ConcurrentHashMap<>();
    Table annotation = clazz.getAnnotation(Table.class);
    String name = annotation.name();
    String className = clazz.getSimpleName();
    map.put("tableName", name);
    map.put("className", className);
    return map;
  }
}

以上这篇利用JAVA反射,读取数据库表名,自动生成对应实体类的操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • Java 通过反射给实体类赋值操作

    表单提交这个方法是挺方便的,但在java来说就显得有些麻烦了, 怎么个麻烦呢,就是当你字段多的时候,你就得一个一个的获取其对应的值,这样代码量就多了起来,其代码量不说,维护也是一个问题. 所以就有了这样一个类,只需把request和实体类对象传进去就行了, 这样就会得到一个有值的实体类对象 下面是代码示例 import java.lang.reflect.Field; import java.lang.reflect.Method; import java.sql.Date; import ja

  • JavaBean实体类处理外键过程解析

    数据库中的表在映射为JavaBean的实体类时,实体类的字段名应与数据库表中的字段名一致.那么外键要怎么处理? 1. JavaBean中实体类中不应该出现外键字段,弊端如下 : 如果出现外键对应的字段,那么将会出现一个对象与另一个对象的属性相对应,这将不是面向对象中的对象与对象对应. 单个外键只能存储一个字符串,用处不大 2.外键处理方式 :数据库表中的外键字段应当转换成外键对应的表的对象,也就是JavaBean的实体类不声明外键的字段,而是声明外键对应数据表类的类型.举个例子,如下 : 数据库

  • springboot+mybatis通过实体类自动生成数据库表的方法

    前言 本章介绍使用mybatis结合mysql数据库自动根据实体类生成相关的数据库表. 首先引入相关的pom包我这里使用的是springboot2.1.8.RELEASE的版本 <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.0</ve

  • java反射机制给实体类相同字段自动赋值实例

    一.封装一个工具类 1.简易版 package net.aexit.construct.acceptance.websky.utils; import java.lang.reflect.Field; import java.lang.reflect.Method; import java.util.HashMap; import java.util.Iterator; import java.util.Map; public class ClassReflection { /** * @par

  • Java实体类(entity)作用说明

    对java实体类的众多理解: A .就是属性类,通常定义在model层里面 B. 一般的实体类对应一个数据表,其中的属性对应数据表中的字段. 好处: 1.对对象实体的封装,体现OO思想. 2.属性可以对字段定义和状态进行判断和过滤 3.把相关信息用一个实体类封装后,我们在程序中可以把实体类作为参数传递,更加方便. C. 说白了就是为了让程序员在对数据库操作的时候不用写SQL语句 D. 就是一个数据库表生成一个类 这样做对数据库操作起来方便 编写代码较少 提高效率 可以使程序员专注逻辑关系 E.

  • 利用JAVA反射,读取数据库表名,自动生成对应实体类的操作

    本代码是利用java反射,读取数据库表自动根据表名生成实体类,数据库采用老牌SQLSERVER 2000,驱动为JTDS,其他数据库可根据情况自定修改. 代码中包含了大部分数据库类型与JAVA类型的转换,少数未包含进去的会在生成代码时打印出来,方面后期查找修改. import java.io.File; import java.io.FileWriter; import java.io.IOException; import java.io.PrintWriter; import java.sq

  • Python使用win32com模块实现数据库表结构自动生成word表格的方法

    本文实例讲述了Python使用win32com模块实现数据库表结构自动生成word表格的方法.分享给大家供大家参考,具体如下: 下载win32模块 下载链接:https://sourceforge.net/projects/pywin32/files/pywin32/ 连接mysql import MySQLdb db_host = "" db_port = 3306 db_name = "" db_user = "" db_pwd = &quo

  • Python利用sqlacodegen自动生成ORM实体类示例

    本文实例讲述了Python利用sqlacodegen自动生成ORM实体类.分享给大家供大家参考,具体如下: 在前面一篇<Python流行ORM框架sqlalchemy安装与使用>我们是手动创建了一个名叫Infos.py的文件,然后定义了一个News类,把这个类作为和我们news数据表的映射. from sqlalchemy.ext.declarative import declarative_base Base = declarative_base() from sqlalchemy impo

  • 利用java反射机制实现自动调用类的简单方法

    1. 新建TestServlet类 package com.yanek.test; import java.io.IOException; import java.lang.reflect.Method; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.ht

  • 利用Java反射机制实现对象相同字段的复制操作

    一.如何实现不同类型对象之间的复制问题? 1.为什么会有这个问题? 近来在进行一个项目开发的时候,为了隐藏后端数据库表结构.同时也为了配合给前端一个更友好的API接口文档(swagger API文档),我采用POJO来对应数据表结构,使用VO来给传递前端要展示的数据,同时使用DTO来进行请求参数的封装.以上是一个具体的场景,可以发现这样子一个现象:POJO.VO.DTO对象是同一个数据的不同视图,所以会有很多相同的字段,由于不同的地方使用不同的对象,无可避免的会存在对象之间的值迁移问题,迁移的一

  • java反射机制根据属性名获取属性值的操作

    一.考虑安全访问范围内的属性,没有权限访问到的属性不读取 /** * 根据属性名获取属性值 * * @param fieldName * @param object * @return */ private String getFieldValueByFieldName(String fieldName, Object object) { try { Field field = object.getClass().getField(fieldName); //设置对象的访问权限,保证对priva

  • ASP获取ACCESS数据库表名及结构的代码

    <html> <head> <title>获取ACCESS数据库表名_www.jb51.net</title> </head> <body style="text-align:left;margin-left:50px;font-family:'arial';font-size:12px"> <form style="padding:5px;margin:5px;margin-left:0px&qu

  • SQL Server数字开头的数据库表名的解决方法

    今天遇到了个郁闷的问题,关于数据库表名的问题. SQL Server的数据库的表名可以用数字开头,但是在查询的时候,不能直接写表名,如下: select *         form 1_tablename 在执行过程中,报错.但是给表名加上中括号,就可以了,如下: select *         from [1_tablename] 用VS中的DataSet开发时,会自动生成SQL语句,但是生成的SQL语句中,有的加上方括号,但是有的没有加, 这在程序执行过程中,就不能确定语句的正确性,而且

  • SQL提取数据库表名及字段名等信息代码示例

    本文向大家介绍了使用SQL语句提取数据库所有表的表名.字段名的实例代码,在SQLserver 中进行了测试,具体内容如下: --查询所有用户表所有字段的特征 SELECT D.Name as TableName, A.colorder AS ColOrder, A.name AS Name, COLUMNPROPERTY(A.ID,A.Name, 'IsIdentity') AS IsIdentity, CASE WHEN EXISTS (SELECT 1 FROM dbo.sysobjects

  • java 利用java反射机制动态加载类的简单实现

    如下所示: ////////////////// Load.java package org.bromon.reflect; import java.util.ArrayList; import java.util.List; public class Load implements Operator { @Override public List<?> act(List<?> params) { // TODO Auto-generated method stub List<

随机推荐

其他