connector.java

来自「J2EE独立开发制作」· Java 代码 · 共 67 行

package com.sql;
import java.sql.*;
import java.io.IOException;
import javax.servlet.jsp.PageContext;
import javax.servlet.jsp.JspException;
import javax.servlet.jsp.JspTagException;
import javax.servlet.jsp.tagext.TagSupport;
import javax.servlet.http.*;
public class connector extends TagSupport 
{
   String driver;
   String user;
   String password;
   String database;
   String table;
   public int doStartTag()throws JspException
       {
        try {
          Class.forName(driver);
          Connection con = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;databaseName="+database, user, password); 
          Statement stat=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		  ResultSet result=stat.executeQuery("select * from "+table);              
          ResultSetMetaData rsmd=result.getMetaData();
          pageContext.getOut().println("<table border=2 cellspacing=1 cellpadding=1>");
          for(int i=1;i<=rsmd.getColumnCount();i++)
      	{
      		  pageContext.getOut().println("<td>"+rsmd.getColumnName(i)+"</td>");
      	}
          while(result.next())
          {
        	  pageContext.getOut().println("<tr>");
        	  for(int i=1;i<=rsmd.getColumnCount();i++)
        	{
        		  
        		 pageContext.getOut().println("<td>"+result.getString(i)+"</td>");
        	}
        	  pageContext.getOut().println("</tr>");
          }
          pageContext.getOut().println("</table>");
             } catch(Exception ioe) {
                                     throw new JspTagException("Error: IOException while writing to the user");
                                      }
                      return SKIP_BODY; 
        }
   public void setDriver( String value ) 
	   {
           driver = value;
        }
   public void setUser( String value ) 
   {
       user = value;
    }
   public void setPassword( String value ) 
   {
       password = value;
    }
   public void setDatabase( String value ) 
   {
       database = value;
    }
   public void setTable( String value ) 
   {
       table = value;
    }
}