// Decompiled by Jad v1.5.7g. Copyright 2000 Pavel Kouznetsov.
// Jad home page: http://www.geocities.com/SiliconValley/Bridge/8617/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi 
// Source File Name:   BuildDb.java

package justbuild;

import com.common.DBConnectionManager;
import java.io.*;

public class BuildDb
{

    public BuildDb()
    {
    }

    public static void buildDbManager(String table_name, String file_name, String file_url, String package_url, String data_name[], String data_type[], String pri_key[])
    {
        StringBuffer sb = new StringBuffer();
        sb.append("package " + package_url + ".database;\r\n");
        sb.append("import java.io.*;\r\n");
        sb.append("import java.util.*;\r\n");
        sb.append("import java.sql.*;\r\n");
        sb.append("import com.common.*;\r\n");
        sb.append("import " + package_url + ".entity.*;\r\n");
        sb.append("public class " + file_name + "Db{\r\n");
        sb.append(buildInsert(table_name, file_name, data_name, data_type) + "\r\n");
        sb.append(buildUpdate(table_name, file_name, data_name, data_type, pri_key) + "\r\n");
        sb.append(buildDel(table_name) + "\r\n");
        sb.append(buildRow(table_name, file_name, data_name, data_type) + "\r\n");
        sb.append(buildFind(table_name, file_name, data_name, data_type) + "\r\n");
        sb.append(buildCount(table_name) + "\r\n");
        sb.append("}\r\n");
        BufferedWriter bw = null;
        try
        {
            File file = new File(file_url);
            if(!file.exists())
                file.mkdirs();
            bw = new BufferedWriter(new FileWriter(file_url + "/" + file_name + "Db.java"));
            bw.write(sb.toString());
            bw.flush();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            if(bw != null)
                try
                {
                    bw.close();
                }
                catch(IOException ex)
                {
                    ex.printStackTrace();
                }
        }
    }

    public static String buildInsert(String tableName, String file_name, String data_name[], String data_type[])
    {
        DBConnectionManager connMgr = DBConnectionManager.getInstance();
        StringBuffer sb = new StringBuffer();
        sb.append("public boolean insertToDb(");
        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 =\"insert into " + tableName + "(");
        if(data_type != null && data_name != null)
        {
            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(") values (");
            if(connMgr.database_type.startsWith("oracle") && "datetime".equals(data_type))
                sb.append("to_date(?,'yyyy-mm-dd hh24:mi:ss')");
            else
                sb.append("?");
            for(int k = 1; k < data_type.length; k++)
            {
                sb.append(",");
                if(connMgr.database_type.startsWith("oracle") && "datetime".equals(data_type))
                    sb.append("to_date(?,'yyyy-mm-dd hh24:mi:ss')");
                else
                    sb.append("?");
            }

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

        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 String buildDel(String tableName)
    {
        StringBuffer sb = new StringBuffer();
        sb.append("public boolean deleteDb(String term) {\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 = \"delete from " + tableName + " where 1=1 \"+ term;\r\n");
        sb.append("try{\r\n");
        sb.append("   pstmt = con.prepareStatement(sql);\r\n");
        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("   System.out.println(\"Delete error: =\"+ 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("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 String buildRow(String tableName, String file_name, String data_name[], String data_type[])
    {
        StringBuffer sb = new StringBuffer();
        sb.append("public " + file_name + "Row get" + file_name + "(String term) {\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("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("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(" }\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");