|
// $Id$ import java.sql.*; public class Table { private Database database; private String name; public Table( Database database, String name ) { this.database = database; this.name = name; } private RowSet execute( String criteria ) throws SQLException { Connection con = database.getConnection(); Statement st = con.createStatement(); ResultSet rs = st.executeQuery( "select * from "+name+ (criteria==null?"":(" where "+criteria)) ); ResultSetMetaData rsmd = rs.getMetaData(); RowSet rows = new RowSet(); int cols = rsmd.getColumnCount(); while (rs.next()) { Row row = new Row(); for (int i=0; i<cols; ++i) { String name = rsmd.getColumnName( i+1 ); String value = rs.getString( i+1 ); row.put( name, value ); } rows.add( row ); } con.close(); return rows; } public Row getRow( String criteria ) throws SQLException { RowSet rs = execute( criteria ); return rs.get( 0 ); } public RowSet getRows( String criteria ) throws SQLException { RowSet rs = execute( criteria ); return rs; } public RowSet getRows() throws SQLException { return getRows( null ); } public void putRow( Row row ) throws SQLException { putRow( row, null ); } public void putRow( Row row, String conditions ) throws SQLException { String ss = ""; if (conditions==null) { ss = "INSERT INTO "+name+" VALUES ("; for (int i=0; i<row.length(); ++i) { String v = row.get( i ); ss += "‘"+v+"‘"; if (i != row.length()-1) ss += ", "; } ss += ")"; } else { ss = "UPDATE "+name+" SET "; for (int i=0; i<row.length(); ++i) { String k = row.getKey( i ); String v = row.get( i ); ss += k+"=‘"+v+"‘"; if (i != row.length()-1) ss += ", "; } ss += " WHERE "; ss += conditions; } System.out.println( "SS "+ss ); Connection con = database.getConnection(); Statement st = con.createStatement(); st.executeUpdate( ss ); } } |
|
|
來(lái)自： smoking_boy > 《我的圖書(shū)館》
