dbutil.java

站长好

package javastudy.tools;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.*;
import java.util.ArrayList;
import java.util.Vector;
public class DBUtil 
{
   public static ArrayList execute(String sqlString) 
   {
      String name;
      int math, chinese, english;
      Connection con = null;//声明一个连接的引用对象
      Statement stat = null;//声明一个连接状态的引用对象
      ResultSet rs = null;//声明一个结果集对象
      try//在搭建窗口时创建数据连接驱动，避免创建连接过程中重复定义 
      {
         Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
      }
      catch(ClassNotFoundException e1) 
      {
         System.out.println("数据库驱动错误");
      }
      try 
      {
         con = DriverManager.getConnection("jdbc:odbc:datasourcename", "", "");//数据源,用户名,密码
         stat = con.createStatement();//得到连接状态
         if(sqlString.trim().substring(0, 1).equalsIgnoreCase("s")) 
         {
            //String t=new java.util.Date().toLocaleString().toString();
            //stat.executeUpdate("insert into tablename (name,math,chinese,english) values('李四',23,43,54)");
            //stat.executeUpdate("update tablename set name='小李四',math=100,chinese=100,english=100 where id=4");
            //stat.executeUpdate("delete from tablename where math<60");
            rs = stat.executeQuery(sqlString);
            ArrayList al=new ArrayList();
            while(rs.next())
            {
            	Vector v=new Vector(5);
            	v.add(rs.getString(1));
            	v.add(rs.getString(2));
            	v.add(rs.getString(3));
            	v.add(rs.getString(4));
            	v.add(rs.getString(5));
            	al.add(v);
            }
            if(!al.isEmpty())
            {
            	return al;
            }
            //return rs;
            /*
            while(rs.next()) 
            {
               name = rs.getString("name");
               math = rs.getInt("math");
               chinese = rs.getInt("chinese");
               english = rs.getInt("english");
               System.out.println("***********************************************");
               System.out.println("id:" + rs.getString("id") + "\t姓名: " + name + "\t" + "数学= " + math + "\t" + "语文= " + chinese + "\t");
               //System.out.println(substance);
               System.out.println("***********************************************");
               System.out.println("");
            }*/
         }
         else 
         {
            stat.executeUpdate(sqlString);
         }
         
         if(rs != null) 
            rs.close();
         if(stat != null) 
            stat.close();
         if(con != null) 
            con.close();
      }
      catch(SQLException e2) 
      {
         //System.out.println("数据库连接失败");
         e2.printStackTrace();
      }
      return null;
   }
   public static void main(String[] args) 
   {
      // TODO: Add your code here
      DBUtil.execute("select * from tablename");
   }
}