/* **Writerluchengbin *DATE:2010-4-28 */
importjava.io.*; importlrapi.lr; importjava.sql.*;
publicclassActions { intsum=0; publicintinit()throwsThrowable{ return0; }//endofinit
publicintaction()throwsThrowable{ try{ Stringsqldriver="com.microsoft.jdbc.sqlserver.SQLServerDriver"; Class.forName(sqldriver); System.out.println("driver is OK!"); Stringurl="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=school"; //建立数据连接,连接school数据库 Stringuser="sa";//数据库用户名 Stringpassword="sa";//数据库密码 Stringsel="select * from student where id > 950";//执行的查询语句 Connectionconn=DriverManager.getConnection(url,user,password); System.out.println("connsucces"); lr.start_transaction("select"); Statementsta=conn.createStatement(); ResultSetrs=sta.executeQuery(sel); System.out.print("\t"+"id"+"\t"+"name"+"\t"+"addr"+"\t"+"tel"+"\n"); //函数输出表的各个字段名字 while(rs.next()) { System.out.print("\t"+rs.getInt(1)); System.out.print("\t"+rs.getString(2)); System.out.print("\t"+rs.getString(3)); System.out.println("\t"+rs.getString(4)); sum=sum+1; } rs.close(); sta.close(); conn.close(); } catch(Exceptione){ e.printStackTrace(); System.out.println("Test Failed"); } lr.message("Sum="+sum); lr.end_transaction("查询表",lr.AUTO); return0; }//endofaction
publicintend()throwsThrowable{ return0; }//endofend |