daocoder.java

一个简单的公文管理系统

                fileStreamStr+="\t\t\t\t}\r\n";
                break;
            }
            fileStreamStr+="\t\t\t\tps = con.prepareStatement(\"insert into "+tableName+" (";

            for(int i=1;i<rsD.getColumnCount()+1;i++){
                if(i==1)
                    fileStreamStr+=" "+rsD.getColumnLabel(i);
                else
                    fileStreamStr+=", "+rsD.getColumnLabel(i);
            }
            fileStreamStr+=") values (";
            for(int i=1;i<rsD.getColumnCount()+1;i++){
                if(i==1)
                    fileStreamStr+=" ?";
                else
                    fileStreamStr+=", ?";
            }
            fileStreamStr+=")\");\r\n";
            for(int i=1;i<rsD.getColumnCount()+1;i++){
                fieldType=getFieldType(rsD,i);
                if (fieldType.equals("int")) fieldType="Int";
                fileStreamStr+="\t\t\t\tps.set"+fieldType+"("+i+", get"+rsD.getColumnLabel(i)+"());\r\n";
            }
            fileStreamStr+="\t\t\t\tlngSQLReturn = ps.executeUpdate();\r\n";
            fileStreamStr+="\t\t\t\tlngReturn = lngSQLReturn;\r\n";
            fileStreamStr+="\t\t\t}\r\n";
            fileStreamStr=getFileStreamStr(fileStreamStr,1);
            fileStreamStr+="\t\treturn lngReturn;\r\n";
            fileStreamStr+="\t}\r\n";

            //delete

            fileStreamStr+="\tpublic boolean delete("+ZZZ+" "+XXX+") {\r\n";

            fileStreamStr+="\t\tConnection con = null;\r\n";
            fileStreamStr+="\t\tPreparedStatement ps = null;\r\n";
            fileStreamStr+="\t\tboolean blnReturn = false;\r\n";

            fileStreamStr+="\t\ttry {\r\n";
            fileStreamStr+="\t\t\tDbConn dbConn = new DbConn();\r\n";
            fileStreamStr+="\t\t\tcon = dbConn.getConnection();\r\n";
            fileStreamStr+="\t\t\tif (con != null) {\r\n";


            fileStreamStr+="\t\t\t\tps = con.prepareStatement(\"delete "+tableName+"  where "+XXX+" = ?\");\r\n";
            fileStreamStr+="\t\t\t\tps.set"+YYY+"(1, "+XXX+");\r\n";
            fileStreamStr+="\t\t\t\tblnReturn = (ps.executeUpdate() == 1);\r\n";
            fileStreamStr+="\t\t\t\tps.close();\r\n";
            fileStreamStr+="\t\t\t}\r\n";
            fileStreamStr+="\t\t\tcon.close();\r\n";
            fileStreamStr=getFileStreamStr(fileStreamStr,2);
            fileStreamStr+="\t\treturn blnReturn;\r\n";
            fileStreamStr+="\t}\r\n";

            //update

            fileStreamStr+="\tpublic boolean update() {\r\n";

            fileStreamStr+="\t\tConnection con = null;\r\n";
            fileStreamStr+="\t\tPreparedStatement ps = null;\r\n";
            fileStreamStr+="\t\tboolean blnReturn = false;\r\n";

            fileStreamStr+="\t\ttry {\r\n";
            fileStreamStr+="\t\t\tDbConn dbConn = new DbConn();\r\n";
            fileStreamStr+="\t\t\tcon = dbConn.getConnection();\r\n";
            fileStreamStr+="\t\t\tif (con != null) {\r\n";


            fileStreamStr+="\t\t\t\tps = con.prepareStatement(\"update "+tableName+" set ";

            for(int i=1;i<rsD.getColumnCount()+1;i++){
                if(i==1)
                    fileStreamStr+=" "+rsD.getColumnLabel(i)+" = ?";
                else
                    fileStreamStr+=", "+rsD.getColumnLabel(i)+" = ?";
            }
            fileStreamStr+=" where "+XXX+" = ?\");\r\n";
            for(int i=1;i<rsD.getColumnCount()+1;i++){
                fieldType=getFieldType(rsD,i);
                if (fieldType.equals("int")) fieldType="Int";
                fileStreamStr+="\t\t\t\tps.set"+fieldType+"("+i+", get"+rsD.getColumnLabel(i)+"());\r\n";
            }
            for(int i=1;i<rsD.getColumnCount()+1;i++){
                fieldType=getFieldType(rsD,i);
                if (fieldType.equals("int")) fieldType="Int";
                int itmp=rsD.getColumnCount()+1;
                fileStreamStr+="\t\t\t\tps.set"+fieldType+"("+itmp+", get"+rsD.getColumnLabel(i)+"());\r\n";
                break;
            }

            fileStreamStr+="\t\t\t\tblnReturn = (ps.executeUpdate() == 1);\r\n";
            fileStreamStr+="\t\t\t\tps.close();\r\n";
            fileStreamStr+="\t\t\t}\r\n";
            fileStreamStr+="\t\t\tcon.close();\r\n";
            fileStreamStr=getFileStreamStr(fileStreamStr,2);
            fileStreamStr+="\t\treturn blnReturn;\r\n";
            fileStreamStr+="\t}\r\n";

            fileStreamStr+="}\r\n";
            //System.out.println(fileStreamStr);
            File file = new File (pathName+className+".java");
            FileWriter out = new FileWriter(file);
            out.write(fileStreamStr);
            out.close();
        }
        catch (Exception ex) {
            ex.printStackTrace();
        }
    }
    private String getFieldType(ResultSetMetaData rsD,int i){
        try {
            String fieldType="String";
            if (rsD.getColumnTypeName(i).equalsIgnoreCase("int")||rsD.getColumnTypeName(i).equalsIgnoreCase("smallint")||rsD.getColumnTypeName(i).equalsIgnoreCase("tinyint")){
                fieldType="int";
            }
            else{
                if (rsD.getColumnTypeName(i).equalsIgnoreCase("datetime")){
                    fieldType="Date";
                }
            }
            return fieldType;
        }
        catch (Exception ex) {
            ex.printStackTrace();
            return "";
        }
    }
    private String getFileStreamStr(String fileStreamStr,int iType){

            if (iType==1){
            fileStreamStr+="\t\t\trs.close();\r\n";
            fileStreamStr+="\t\t\trs = null;\r\n";
            fileStreamStr+="\t\t\tps.close();\r\n";
            fileStreamStr+="\t\t\tps = null;\r\n";
            fileStreamStr+="\t\t\tcon.close();\r\n";
            fileStreamStr+="\t\t\tcon = null;\r\n";
            }
            fileStreamStr+="\t\t}\r\n";
            //fileStreamStr+="\t\tcatch (NamingException namingException) {\r\n";
            //fileStreamStr+="\t\t}\r\n";
            fileStreamStr+="\t\tcatch (SQLException sqlException) {\r\n";
            fileStreamStr+="\t\t\tSystem.out.println(sqlException.getMessage());\r\n";
            fileStreamStr+="\t\t}\r\n";
            fileStreamStr+="\t\tfinally {\r\n";
            if (iType==1){
            fileStreamStr+="\t\t\tif (rs != null) {\r\n";
            fileStreamStr+="\t\t\t\ttry {\r\n";
            fileStreamStr+="\t\t\t\t\trs.close();\r\n";
            fileStreamStr+="\t\t\t\t}\r\n";
            fileStreamStr+="\t\t\t\tcatch (SQLException sqlException) {\r\n";
            fileStreamStr+="\t\t\t\t}\r\n";
            fileStreamStr+="\t\t\t\trs = null;\r\n";
            fileStreamStr+="\t\t\t}\r\n";
            }
            fileStreamStr+="\t\t\tif (ps != null) {\r\n";
            fileStreamStr+="\t\t\t\ttry {\r\n";
            fileStreamStr+="\t\t\t\t\tps.close();\r\n";
            fileStreamStr+="\t\t\t\t}\r\n";
            fileStreamStr+="\t\t\t\tcatch (SQLException sqlException) {\r\n";
            fileStreamStr+="\t\t\t\t}\r\n";
            fileStreamStr+="\t\t\t\tps = null;\r\n";
            fileStreamStr+="\t\t\t}\r\n";
            fileStreamStr+="\t\t\tif (con != null) {\r\n";
            fileStreamStr+="\t\t\t\ttry {\r\n";
            fileStreamStr+="\t\t\t\t\tcon.close();\r\n";
            fileStreamStr+="\t\t\t\t}\r\n";
            fileStreamStr+="\t\t\t\tcatch (SQLException sqlException) {\r\n";
            fileStreamStr+="\t\t\t\t}\r\n";
            fileStreamStr+="\t\t\t\tcon = null;\r\n";
            fileStreamStr+="\t\t\t}\r\n";
            fileStreamStr+="\t\t}\r\n";
            return fileStreamStr;
    }
    public static void main(String[] args) {
        DaoCoder daoCoder = new DaoCoder();
        daoCoder.pathName="D:\\JDYM\\src\\com\\jasson\\business\\system\\";

        daoCoder.className="DocTypeDAO";
        daoCoder.tableName="TType";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocSpeedDAO";
        daoCoder.tableName="TSpeed";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocKindDAO";
        daoCoder.tableName="TKind";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocCopyDAO";
        daoCoder.tableName="TCopy";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocSecretDAO";
        daoCoder.tableName="TSecret";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocAttributeDAO";
        daoCoder.tableName="TAttribute";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocMediaTypeDAO";
        daoCoder.tableName="TMediaType";
        daoCoder.writeDaoToFile();

        daoCoder.className="DocControlTypeDAO";
        daoCoder.tableName="TControlType";
        daoCoder.writeDaoToFile();

    }
}