现在的位置: 首页 > 综合 > 正文

JDBC1

2013年12月05日 ⁄ 综合 ⁄ 共 2146字 ⁄ 字号 评论关闭

 import java.sql.*;
public class DbTest
{   private Connection conn=null;
    private ResultSet rs=null;
    private Statement stm=null;
public DbTest(){}
public void openOdbcDb(String dsnn,String user,String password)
{try{
String url="jdbc:odbc:"+dsnn;
     Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
         conn=DriverManager.getConnection(url,user,password);
   
}catch(Exception e){System.err.println("aq.executeQuery: " + e.getMessage());}
        }
   
public void openJdbcDb(String dsnn)
{openJdbcDb(dsnn,"sa","sa");
        }
public void openJdbcDb(String dsnn,String user,String password)
{try{Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName="+dsnn;
        conn= DriverManager.getConnection(url,user,password);
}catch(Exception e){System.err.println("aq.executeQuery: " + e.getMessage());}
        }
public ResultSet executeQuery(String sql)
{rs=null;
     try{
 stm=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
     rs=stm.executeQuery(sql);

}catch(Exception e){System.err.println("aq.executeQuery: " + e.getMessage());}
return rs;
}
   
public void executeUpdate(String sql)
{ try{
  stm=conn.createStatement();
      stm.executeUpdate(sql);
 }catch(Exception e){System.err.println("aq.executeQuery: " + e.getMessage());}
     }
    public void closeDb()
{if(rs!=null)
  {try{rs.close();
       rs=null;
        }catch(Exception e){}
       }
   if(stm!=null)
   {try{stm.close();
   stm=null;
   }catch(Exception e){}
   }
   if(conn!=null)
   {try{
   conn.close();
   conn=null;
   }
   catch(Exception e){}
   }
    }
public static void main(String [] args)throws Exception
{DbTest test=new DbTest();
     test.testDb("select * from liuyan_tb join fuzhuang_tb on liuyan_tb.ID=fuzhuang_tb.ID");

     }
public  void testDb(String sql)throws Exception
{ ResultSet rst=null;
  openJdbcDb("clother");
  System.out.println(sql);
      rst=executeQuery(sql);
for(int j=1; j<=rst.getMetaData().getColumnCount(); j++)
 {System.out.print(rst.getMetaData().getColumnName(j)+"   ");}
   System.out.println("");
     while (rst.next())
     {  for(int j=1; j<=rst.getMetaData().getColumnCount(); j++)
     {
       System.out.print( rst.getObject(j)+"   ");
 }
 System.out.println("");
     }

    closeDb();
}
}

抱歉!评论已关闭.