?? builddb.java
字號(hào):
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[])
{
}
}
?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -