加载中...

Hibernate生成实体类-手工写法(一)

BaseDao

  1. package com.pb.dao;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  10. public class BaseDao {
  11.     protected Connection conn;
  12.     protected PreparedStatement ps;
  13.     protected ResultSet rs;
  15.     public Connection getConnection() {
  16.         String driver = "oracle.jdbc.driver.OracleDriver";
  17.         String url = "jdbc:oracle:thin:@localhost:1521:orcl";
  18.         String username = "accp";
  19.         String password = "accp";
  20.         try {
  21.             Class.forName(driver);
  23.             conn = DriverManager.getConnection(url, username, password);
  24.         } catch (ClassNotFoundException e) {
  25.             e.printStackTrace();
  26.         } catch (SQLException e) {
  27.             e.printStackTrace();
  28.         }
  29.         return conn;
  30.     }
  32.     public void closeConnection() {
  33.         if (rs != null) {
  34.             try {
  35.                 rs.close();
  36.             } catch (SQLException e) {
  37.                 e.printStackTrace();
  38.             }
  39.         }
  40.         if (ps != null) {
  41.             try {
  42.                 ps.close();
  43.             } catch (SQLException e) {
  44.                 e.printStackTrace();
  45.             }
  46.         }
  47.         if (conn != null) {
  48.             try {
  49.                 conn.close();
  50.             } catch (SQLException e) {
  51.                 e.printStackTrace();
  52.             }
  53.         }
  54.     }
  55.     
  56.     public ResultSet executeQuery(String sql,Object [] params){
  57.         getConnection();
  58.         
  59.         try {
  60.             ps=conn.prepareStatement(sql);
  61.         if(params!=null){
  62.             for (int i = 0; i < params.length; i++) {
  63.             
  64.                     ps.setObject(i+1, params[i]);
  65.                 
  66.             }
  67.         }
  68.         rs=ps.executeQuery();
  69.         } catch (SQLException e) {
  70.             e.printStackTrace();
  71.         }
  72.         return rs;
  73.     }
  74.     public int executeUpdate(String sql,Object [] params){
  75.         int updateNum=-1;
  76.         getConnection();
  77.         
  78.         try {
  79.             ps=conn.prepareStatement(sql);
  80.         if(params!=null){
  81.             for (int i = 0; i < params.length; i++) {
  82.             
  83.                     ps.setObject(i+1, params[i]);
  84.                 
  85.             }
  86.         }
  87.         updateNum=ps.executeUpdate();
  88.         } catch (SQLException e) {
  89.             e.printStackTrace();
  90.         }finally{
  91.             this.closeConnection();
  92.         }
  93.         return updateNum;
  94.     }
  95.     
  96. }

tableDao仍然是Dao层

  1. package com.pb.dao;
  3. import java.util.List;
  4. import java.util.Map;
  8. public interface TableDao {
  9.     
  10.     public List<String> getTableName();
  11.     
  12.     public Map<String, String> getCols(String tableName);
  14. }

tableDaoImpl实现数据访问

  1. package com.pb.dao.impl;
  3. import java.sql.ResultSet;
  4. import java.sql.SQLException;
  5. import java.util.ArrayList;
  6. import java.util.HashMap;
  7. import java.util.Iterator;
  8. import java.util.List;
  9. import java.util.Map;
  11. import com.pb.dao.BaseDao;
  12. import com.pb.dao.TableDao;
  14. public class TableDaoImpl extends BaseDao implements TableDao {
  15. 　//当前用户下的所有表名
  16.     @Override
  17.     public List<String> getTableName() {
  18.         List<String> tableNameList = null;
  19.         try {
  20.             String sql = "select * from user_tables";
  21.             Object[] params = {};
  22.             ResultSet rs = super.executeQuery(sql, params);
  23.             if (rs != null) {
  24.                 tableNameList = new ArrayList<String>();
  25.                 while (rs.next()) {
  26.                     tableNameList.add(rs.getString("TABLE_NAME"));
  27.                     
  28.                 }
  29.             }
  30.         } catch (SQLException e) {
  31.             e.printStackTrace();
  32.         } finally {
  33.             super.closeConnection();
  34.         }
  36.         return tableNameList;
  37.     }
  38. 　　//指定表名的所有字段
  39.     @Override
  40.     public Map<String, String> getCols(String tableName) {
  41.         Map<String, String> map=null;
  42.         try {
  43.         String sql="select * from user_tab_cols where table_name=?";
  44.         Object [] params={tableName};
  45.         ResultSet rs=super.executeQuery(sql, params);
  46.         if(rs!=null){
  47.             map=new HashMap<String, String>();
  48.             while(rs.next()){
  49.                 map.put(rs.getString("COLUMN_NAME"), rs.getString("DATA_TYPE"));
  50.             }
  51.         }
  52.         } catch (SQLException e) {
  53.             e.printStackTrace();
  54.         } finally {
  55.             super.closeConnection();
  56.         }
  57.         return map;
  58.     }
  60. }

业务层biz

  1. TableService接口
  1. package com.pb.biz;
  3. import java.util.List;
  4. import java.util.Map;
  6. public interface TableService {
  7. 　　
  8.     public List<String> getTableName();
  9.     
  10.     public Map<String, String> getCols(String tableName);
  11. }
  1. TableService接口业务层实现
  1. package com.pb.biz.impl;
  3. import java.util.List;
  4. import java.util.Map;
  6. import com.pb.biz.TableService;
  7. import com.pb.dao.TableDao;
  8. import com.pb.dao.impl.TableDaoImpl;
  10. public class TableServiceImpl implements TableService {
  11.     private TableDao tableDao=new TableDaoImpl();
  12.     @Override
  13.     public List<String> getTableName() {
  14.         return tableDao.getTableName();
  15.     }
  17.     @Override
  18.     public Map<String, String> getCols(String tableName) {
  19.         return tableDao.getCols(tableName);
  20.     }
  22. }

测试类

  1. package com.pb.test;
  3. import java.io.File;
  4. import java.io.FileNotFoundException;
  5. import java.io.FileOutputStream;
  6. import java.io.IOException;
  7. import java.util.List;
  8. import java.util.Map;
  9. import java.util.Scanner;
  11. import com.pb.biz.TableService;
  12. import com.pb.biz.impl.TableServiceImpl;
  16. public class DemoTest {
  17.     public static TableService tableService=new TableServiceImpl();
  18.     public static Scanner input=new Scanner(System.in);
  19.     public static void main(String[] args) {
  20.         Map<String, String> map;
  21.         //类名
  22.         String className=null;
  23.         
  24.         //获取accp用户下的全部表名
  25.     List<String> tableNameList=getTableName();
  26.     System.out.println("请输入你需要的表名");
  27.     String tableName=input.next().toUpperCase();
  28.     boolean flag=false;
  29.     for (String s : tableNameList) {
  30.         if(s.contains(tableName)){
  31.             flag=true;
  32.             
  33.         }
  34.     }
  35.     
  36.     
  37.     if(flag==true){
  38.         System.out.println("表已经找到表名为"+tableName);
  39.         //输出表名并生成类名
  40.         className ="public class " + tableName.substring(0,1)+tableName.substring(1).toLowerCase()+" {  \n";
  41.         //要建立的包名
  42.         System.out.println("请输入要建立的包名:");
  43.         String pack="package "+input.next()+" ;\n";
  44.         //获取表中的字段
  45.          map =tableService.getCols(tableName);
  46.         //根据表名生成文件名
  47.          String filename=tableName.substring(0,1)+tableName.substring(1).toLowerCase()+".java";
  48.             //找到表中的字段
  49.             map=getTableCols(tableName);
  50.             //建立属性字符串
  51.             String proerty=getProerty(map);
  52.             //无参数构造方法
  53.             String con=getconString(tableName);
  54.             //get方法
  55.             String getter=getMethod(map);
  56.             //setter方法
  57.             String setter=setMethod(map);
  58.             //生成总字符串
  59.             String str=pack+className+proerty+con+getter+setter+"}";
  60.             //写入文件
  61.             File file=new File("d:"+File.separator+filename);
  62.             FileOutputStream fos=null;
  63.             try {
  64.                  fos=new FileOutputStream(file);
  65.                 fos.write(str.getBytes());
  66.             } catch (FileNotFoundException e) {
  67.                 e.printStackTrace();
  68.             } catch (IOException e) {
  69.                 e.printStackTrace();
  70.             }finally{
  71.                 try {
  72.                     fos.close();
  73.                 } catch (IOException e) {
  74.                     e.printStackTrace();
  75.                 }
  76.             }
  77.     }else{
  78.         System.out.println("没有这个表"+tableName);
  79.     }
  80.     
  81.     }
  82.     //当前用户下所有表名
  83.     public static List<String> getTableName(){
  84.         return tableService.getTableName();
  85.     }
  86.     //字段
  87.     public static Map<String,String> getTableCols(String tableName){
  88.         return tableService.getCols(tableName);
  89.     }
  90.     //无参数构造方法
  91.         public static String getconString(String tableName){
  92.             String conString=" \n // 无参数构造方法\n public "+tableName.substring(0,1)+tableName.substring(1).toLowerCase()+"(){\n\n}\n";
  93.             return conString;
  94.         }
  95.         
  96.     //将字段转为字符串属性
  97.     public static String getProerty(Map<String,String> map){
  98.         String str="// Fields \n";
  99.         for(String s:map.keySet()){
  100.             if(map.get(s).equals("NUMBER")){
  101.                 str+=" \n private " +"int "+s.toLowerCase()+";\n";
  102.             }else  if(map.get(s).equals("VARCHAR2")){
  103.                 str+=" \n private " +"String "+s.toLowerCase()+";\n";
  104.             }else  if(map.get(s).equals("DATE")){
  105.                 str+=" \n private " +"Date "+s.toLowerCase()+";\n";
  106.             }else{
  107.                 str+=" \n private " +map.get(s)+" "+s.toLowerCase()+";\n";
  108.             }
  109.         }
  110.         return str;
  111.     }
  112.     //get方法
  113.     //将字段转为get方法
  114.         public static String getMethod(Map<String,String> map){
  115.             String str="//getter方法\n";
  116.             for(String s:map.keySet()){
  117.                 if(map.get(s).equals("NUMBER")){
  118.                     str+=" \n public " +"int "+"get"+s.substring(0,1)+s.substring(1).toLowerCase()+"(){\n  return  this."+s.toLowerCase()+"; \n}";
  119.                 }else  if(map.get(s).equals("VARCHAR2")){
  120.                     str+="  \n public " +"String "+"get"+s.substring(0,1)+s.substring(1).toLowerCase()+"(){\n  return  this."+s.toLowerCase()+"; \n}";
  121.                 }else  if(map.get(s).equals("DATE")){
  122.                     str+="  \n public " +"Date "+"get"+s.substring(0,1)+s.substring(1).toLowerCase()+"(){\n  return  this."+s.toLowerCase()+"; \n}";
  123.                 }else{
  124.                     str+=" \n public " +map.get(s)+" "+"get"+s.substring(0,1)+s.substring(1).toLowerCase()+"(){\n  return  this."+s.toLowerCase()+"; \n}";
  125.                 }
  126.             }
  127.             return str;
  128.         }
  129.         //set方法
  130.         //将字段转为set方法
  131.             public static String setMethod(Map<String,String> map){
  132.                 String str="\n//setter方法\n";
  133.                 for(String s:map.keySet()){
  134.                     if(map.get(s).equals("NUMBER")){
  135.                         str+=" \n public  void  " +"set"+s.substring(0,1)+s.substring(1).toLowerCase()+"("+"int "+s.toLowerCase()+") {\n this."+s.toLowerCase()+"="+s.toLowerCase()+";\n}\n";
  136.                     }else  if(map.get(s).equals("VARCHAR2")){
  137.                         str+="  \n public  void " +"set"+s.substring(0,1)+s.substring(1).toLowerCase()+"("+"String "+s.toLowerCase()+") {\n this."+s.toLowerCase()+"="+s.toLowerCase()+";\n}\n";
  138.                     }else  if(map.get(s).equals("DATE")){
  139.                         str+="  \n public  void " +"set"+s.substring(0,1)+s.substring(1).toLowerCase()+"("+"Date "+s.toLowerCase()+") {\n this."+s.toLowerCase()+"="+s.toLowerCase()+";\n}\n";
  140.                     }else{
  141.                         str+=" \n public   void " +" "+"set"+s.substring(0,1)+s.substring(1).toLowerCase()+"("+map.get(s)+"  "+s.toLowerCase()+") {\n this."+s.toLowerCase()+"="+s.toLowerCase()+";\n}\n";
  142.                     }
  143.                 }
  144.                 return str;
  145.             }
  146. }

不用框架自己写的，还有漏吊的，还有很多，没有写明白的，望指正

还没有评论.