operatedatabase.java

java学习课件

/*数据库操作类OperateDatabase.java*/
import java.sql.*;
public class OperateDatabase
{
 Connection con;
 PreparedStatement prepare; 
 Statement  statement;
 /*构造对象方法*/
 public OperateDatabase(String datasource,String user,String pass)// 构造方法
  {
   try
   {
     Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
     con=DriverManager.getConnection("jdbc:odbc:"+ datasource, user,pass);
   }
   catch(Exception ee)
   { System.out.println("data source ERROR:"+ee); }
  }//构造方法结束
 /*一般操作方法*/ 
 public int anyOperate(String sqlStr)  //执行操作方法
  {
   try
   {
    statement=con.createStatement();  //建立语句对象
    statement.execute(sqlStr );  //执行Sql操作
    return 1;    //操作成功
   } 
   catch(Exception err1)
   {
    System.out.println("执行操作错误："+err1);
    return 0;   //操作失败
   }  
  } //执行操作方法结束
 public int insert(String insertSql,String [] values )  // 插入记录
  {
    try
    {
     prepare=con.prepareStatement(insertSql);  //建立语句对象
     for(int i=0; i<values.length; i++)  prepare.setString(i+1,values[i]);
     prepare.execute();  //执行Sql操作
     return 1;    //插入成功
    } 
    catch(Exception err)
    {
     System.out.println("插入记录错误"+err);
     return 0;   //插入失败
    }  
  } //插入记录结束 
  /*查询记录方法*/
 public ResultSet query(String queryStr)//查询方法，queryStr为SQL查询语句串 
  { 
   try
    { statement=con.createStatement(); //创建语句对象
      ResultSet rs=statement.executeQuery(queryStr);//执行查询操作
      return rs;  //返回查询结果集
    }
    catch(Exception err)
    { System.out.println("取数据ERROR:"+err);
      return null;  //查询失败，返回空
    }
  }//查询方法结束
 /*修改记录方法*/ 
 public int modify(String modiStr,String[] values)
  {
   try
   {
     prepare=con.prepareStatement(modiStr);  //创建语句对象
     for(int i=1;i<=values.length;i++) prepare.setString(i,values[i-1]);
     prepare.execute(); //执行操作
     return 1;  //修改成功
   }
   catch(Exception err)
   {
   	 System.out.println("数据库修改操作失败!!!"+err);
     return 0;  //修改失败
   }
  } //修改记录方法结束
  /*删除记录方法*/
 public int delete(String tabName, String cond) 
  {
   try
   {
     String sqlstr="DELETE FROM "+tabName+" WHERE  "+cond;
     statement=con.createStatement();
     statement.execute(sqlstr);
     return 1;  //删除成功
   } 
   catch(Exception err) 
   {
     System.out.println("删除记录失败："+err);
     return 0;   //删除失败
   }  
  } //删除记录方法结束
}