sqlresult2.java

java程序设计入门教程 书上的源代码 学习JAVA非常好的入门教材代码推荐给大家

/************************ SqlResult.java ******************/
import java.sql.*;
public class SqlResult
  {
  private String sql;
  private Connection con;
  public SqlResult(String sql, Connection con)
    {
    this.sql = sql;
    this.con = con;
    }
  public String toString()
    {
    StringBuffer out = new StringBuffer();
    try
      {
      Statement statement = con.createStatement();
      if (statement.execute(sql))
        {
        ResultSet rs = statement.getResultSet();    
        out.append("<TABLE>\n");
        ResultSetMetaData rsmd = rs.getMetaData();
        int numcols = rsmd.getColumnCount();
        out.append("<TR>");
        for (int i = 1; i <= numcols; i++)
          out.append("<TH>" + rsmd.getColumnLabel(i));
        out.append("</TR>\n");
        while (rs.next())
          {
          out.append("<TR>");
          for (int i = 1; i <= numcols; i++)
            {
            out.append("<TD>");
            Object obj = rs.getObject(i);
            if (obj != null)
              out.append(obj.toString());
            else
              out.append("&nbsp;");
            }
          out.append("</TR>\n");
          }
        out.append("</TABLE>\n");
        }
      else
        {
        out.append("<B>Records Affected:</B> " +
                   statement.getUpdateCount());
        }
      }
    catch (SQLException e)
      {
      out.append("</TABLE><H1>ERROR:</H1> "+e.getMessage());
      }
    return out.toString();
    }
  }