builddb.java

自动生成JAVA BEAN工具

        sb.append("}\r\n");
        sb.append("try{\r\n");
        sb.append("stmt.close();\r\n");
        sb.append("}\r\n");
        sb.append("catch(Exception e){\r\n");
        sb.append("e.getMessage();\r\n");
        sb.append("}");
        sb.append("connMgr.freeConnection(\"idb\", con);\r\n");
        sb.append("connMgr.release();\r\n");
        sb.append("}\r\n");
        sb.append("return msg;\r\n");
        sb.append("}\r\n");
        return sb.toString();
    }

    public static String buildFind(String tableName, String file_name, String data_name[], String data_type[])
    {
        StringBuffer sb = new StringBuffer();
        sb.append("static public Collection findByTerm(String term, int startRow, int endRow) throws SQLException {\r\n");
        sb.append("DBConnectionManager connMgr = DBConnectionManager.getInstance();\r\n");
        sb.append("Connection con = connMgr.getConnection(\"idb\");\r\n");
        sb.append("Statement stmt = null;\r\n");
        sb.append("ResultSet rs = null;\r\n");
        sb.append(file_name + "Row msg = null;\r\n");
        sb.append("String sql = \"select ");
        for(int i = 0; i < data_name.length; i++)
            if(i == 0)
            {
                sb.append(data_name[i]);
            } else
            {
                sb.append(",");
                sb.append(data_name[i]);
            }

        sb.append(" from " + tableName + " where 1=1 \"+term;\r\n");
        sb.append("Vector vc = new Vector();\r\n");
        sb.append("int i=0;\r\n");
        sb.append("try{\r\n");
        sb.append("stmt = con.createStatement();\r\n");
        sb.append("rs = stmt.executeQuery(sql);\r\n");
        sb.append("while (rs.next()) {\r\n");
        sb.append("i++;\r\n");
        sb.append("if ( (i >= startRow) && (i <= endRow || endRow == -1)) {\r\n");
        sb.append("msg = new " + file_name + "Row();\r\n");
        for(int k = 0; k < data_name.length; k++)
            if("int".equals(data_type[k]))
                sb.append("msg." + data_name[k] + "=rs.getInt(\"" + data_name[k] + "\");\r\n");
            else
                sb.append("msg." + data_name[k] + "=rs.getString(\"" + data_name[k] + "\");\r\n");

        sb.append("vc.addElement(msg);\r\n");
        sb.append("  }\r\n");
        sb.append(" }\r\n");
        sb.append("}\r\n");
        sb.append("catch (SQLException e) {\r\n");
        sb.append("System.out.println(\"get" + file_name + "Row eeror:\"+e.toString());\r\n");
        sb.append("e.printStackTrace();\r\n");
        sb.append("}\r\n");
        sb.append("finally {\r\n");
        sb.append("try {\r\n");
        sb.append("rs.close();\r\n");
        sb.append("}\r\n");
        sb.append("catch (Exception e) {\r\n");
        sb.append("e.getMessage();\r\n");
        sb.append("}\r\n");
        sb.append("try{\r\n");
        sb.append("stmt.close();\r\n");
        sb.append("}\r\n");
        sb.append("catch(Exception e){\r\n");
        sb.append("e.getMessage();\r\n");
        sb.append("}");
        sb.append("connMgr.freeConnection(\"idb\", con);\r\n");
        sb.append("connMgr.release();\r\n");
        sb.append("}\r\n");
        sb.append("return vc;\r\n");
        sb.append("}\r\n");
        return sb.toString();
    }

    public static String buildCount(String tableName)
    {
        StringBuffer sb = new StringBuffer();
        sb.append("static public int getRowCountByTerm(String term) throws SQLException {\r\n");
        sb.append("DBConnectionManager connMgr = DBConnectionManager.getInstance();\r\n");
        sb.append("Connection con = connMgr.getConnection(\"idb\");\r\n");
        sb.append("Statement stmt = null;\r\n");
        sb.append("ResultSet rs = null;\r\n");
        sb.append("String sql = \"select count(*) from " + tableName + " where 1=1  \" + term;\r\n");
        sb.append("int i = -1;\r\n");
        sb.append("try{\r\n");
        sb.append("stmt = con.createStatement();\r\n");
        sb.append("rs = stmt.executeQuery(sql);\r\n");
        sb.append("  if (rs.next()) {\r\n");
        sb.append("    i = rs.getInt(1);\r\n");
        sb.append("  }\r\n");
        sb.append("}\r\n");
        sb.append("catch (SQLException e) {\r\n");
        sb.append("e.printStackTrace();\r\n");
        sb.append("}\r\n");
        sb.append("finally {\r\n");
        sb.append("try {\r\n");
        sb.append("rs.close();\r\n");
        sb.append("}\r\n");
        sb.append("catch (Exception e) {\r\n");
        sb.append("e.getMessage();\r\n");
        sb.append("}\r\n");
        sb.append("try{\r\n");
        sb.append("stmt.close();\r\n");
        sb.append("}\r\n");
        sb.append("catch(Exception e){\r\n");
        sb.append("e.getMessage();\r\n");
        sb.append("}");
        sb.append("connMgr.freeConnection(\"idb\", con);\r\n");
        sb.append("connMgr.release();\r\n");
        sb.append("}\r\n");
        sb.append("return i;\r\n");
        sb.append("}\r\n");
        return sb.toString();
    }

    public static String buildUpdate(String tableName, String file_name, String data_name[], String data_type[], String pri_key[])
    {
        DBConnectionManager connMgr = DBConnectionManager.getInstance();
        StringBuffer sb = new StringBuffer();
        sb.append("public boolean updateDb(");
        sb.append(file_name + "Row msg){\r\n");
        sb.append("DBConnectionManager connMgr = DBConnectionManager.getInstance();\r\n");
        sb.append("Connection con = connMgr.getConnection(\"idb\");\r\n");
        sb.append("PreparedStatement pstmt = null;\r\n");
        sb.append("boolean sign = false;\r\n");
        sb.append("String sql =\"update " + tableName + " set ");
        String tempStr = "";
        if(data_type != null && data_name != null)
        {
            for(int i = 0; i < data_name.length; i++)
                if(!pri_key[i].equals("1"))
                {
                    if(connMgr.database_type.startsWith("oracle") && "datetime".equals(data_type))
                        tempStr = tempStr + data_name[i] + "=to_date(?,'yyyy-mm-dd hh24:mi:ss')";
                    else
                        tempStr = tempStr + data_name[i] + "=?";
                    tempStr = tempStr + ",";
                }

            tempStr = tempStr.substring(0, tempStr.length() - 1);
            sb.append(tempStr);
            sb.append(" where 1=1 ");
            for(int i = 0; i < data_name.length; i++)
                if(pri_key[i].equals("1"))
                    sb.append(" and " + data_name[i] + "=?");

            sb.append("\";\r\n");
        }
        sb.append("try {\r\n");
        sb.append("pstmt = con.prepareStatement(sql);\r\n");
        int num = 1;
        for(int n = 0; n < data_name.length; n++)
            if(!pri_key[n].equals("1"))
                if("int".equals(data_type[n]))
                {
                    sb.append("pstmt.setInt(" + num + ",msg." + data_name[n] + ");\r\n");
                    num++;
                } else
                {
                    sb.append("pstmt.setString(" + num + ",msg." + data_name[n] + ");\r\n");
                    num++;
                }

        for(int n = 0; n < data_name.length; n++)
            if(pri_key[n].equals("1"))
                if("int".equals(data_type[n]))
                {
                    sb.append("pstmt.setInt(" + num + ",msg." + data_name[n] + ");\r\n");
                    num++;
                } else
                {
                    sb.append("pstmt.setString(" + num + ",msg." + data_name[n] + ");\r\n");
                    num++;
                }

        sb.append("pstmt.executeUpdate();\r\n");
        sb.append("sign = true;\r\n");
        sb.append("}\r\n");
        sb.append("catch (SQLException e) {\r\n");
        sb.append("e.printStackTrace();\r\n");
        sb.append("}\r\n");
        sb.append(" finally {\r\n");
        sb.append("try {\r\n");
        sb.append("pstmt.close();\r\n");
        sb.append("}\r\n");
        sb.append("catch (SQLException e) {\r\n");
        sb.append("e.getMessage();\r\n");
        sb.append("}\r\n");
        sb.append("connMgr.freeConnection(\"idb\", con);\r\n");
        sb.append("connMgr.release();\r\n");
        sb.append("}\r\n");
        sb.append("return sign;\r\n");
        sb.append("}\r\n");
        return sb.toString();
    }

    public static void main(String args[])
    {
    }
}