databasemanager.java

文件中采用Java编写的程序

import java.io.*;
import java.net.*;
import java.util.*;
import java.net.URL;
import java.sql.*;
import javax.swing.table.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class DataBaseManager
{
	java.sql.Connection con;
       ResultSet rs;	
	Statement stmt;
        
        //String search_str=subString(s);
    
    /*为数据库管理器的构造函数,进行数据库链接*/
       public DataBaseManager(String l)
	{
            
        try
           {
		try
                {
		        Class.forName( "sun.jdbc.odbc.JdbcOdbcDriver" );/*加载指定的驱动程序*/
		   }
                catch(java.lang.ClassNotFoundException e)
                  {
                     System.err.print("ClassNOtFoundException:");
                     System.err.println(e.getMessage());
                     System.err.println("Failed to load JDBC/ODBC driver." );
                  }
              con=DriverManager.getConnection(l);
              DatabaseMetaData dma=con.getMetaData();
              System.out.println("连接的数据库:"+dma.getURL());
              System.out.println("Driver     :"+dma.getDriverName());
              System.out.println("Version    :"+dma.getDriverVersion());
		      stmt=con.createStatement();
	     }
	       
	catch(SQLException ex)
           {
                while(ex!=null)
               {
                       System.out.println("数据库异常被捕获了");
                       System.out.println(ex.getSQLState());
                       System.out.println(ex.getMessage());
                       System.out.println(ex.getErrorCode());
                       ex=ex.getNextException();
               }
           }

	}

       
       	
/*查找函数*/
       public String querySql(String buf,String table,String sbuf,String s)
	{
            String search_str=s;
		    String s_buf=sbuf;
		    String tab=table;
            String temp="%"+search_str+"%";		
		    //System.out.println(temp);
	        //String strSQL="select * from titles where pub_id like '"+temp+"'";
		    String strSQL="select * from "+tab+" where "+s_buf+" like "+"\'"+temp+"\'";
		    //System.out.println(strSQL);

   		try
                 {
		     rs=stmt.executeQuery(strSQL);
                   rs.next();
                    //System.out.println("This is content "+rs.getString(buf));
		     String result=rs.getString(buf);
                   return result;
	          }
	       catch(SQLException ex)
	        {
		
                    while(ex!=null)
                    {
                       System.out.println("数据库异常被捕获了");
                       System.out.println(ex.getSQLState());
                       System.out.println(ex.getMessage());
                       System.out.println(ex.getErrorCode());
                       ex=ex.getNextException();
                    }
		    return null;
	        }
	
       }


        public boolean updateSql(String buf,String s)
        {
			String search_str=s;
			String temp="%"+search_str+"%";
			String strSQL="select * from titles where pub_id like '"+temp+"'";

        	try{
        	stmt.executeUpdate(strSQL);
        	con.commit();
                return true;
        	
                 }
        catch(SQLException sqle)
               {
        	System.out.println(sqle.toString());
        	return false;
                 }
        
        }
       // public Vector additems

	public boolean insertSql(String table,String buf,String s)
	{
		String tab=table;
		String write_Str=s;
		String write_buf=buf;
		String strSQL="INSERT INTO "+tab+" ("+write_buf+") "+" values "+" ("+write_Str+")";
        System.out.println(strSQL);
		try
		{
			stmt.executeUpdate(strSQL);
			return true;			
		}
		catch(SQLException ex)
		{
			while(ex!=null)
			{
				System.out.println("数据库异常被捕获了");
				System.out.println(ex.getSQLState());
				System.out.println(ex.getMessage());
				System.out.println(ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println(ex.toString());
			}
			
			return false;
		}

	}
	
	/*删除记录函数*/
	public boolean deleteSql(String table,String buf,String s)
	{
		
		
		String tab=table;
		String strSQL="DELETE FROM "+tab+" where "+ buf +"=" +"\'"+s+"\'";
		//System.out.println(strSQL);
		try
		{
			stmt.executeUpdate(strSQL);
			System.out.println("删除成功");
			return true;			
		}
		catch(SQLException ex)
		{
			while(ex!=null)
			{
				System.out.println("数据库异常被捕获了");
				System.out.println(ex.getSQLState());
				System.out.println(ex.getMessage());
				System.out.println(ex.getErrorCode());
				ex=ex.getNextException();
				//System.out.println(ex.toString());
			}
			
			return false;
		}		
		
	}

	/*断开与数据库的链接*/
        public void closeConnection()
        {
        	try
        	{
        		con.close();
				System.out.println("已退出数据库");
        	}
        	catch(SQLException ex)
        	{
                    while(ex!=null)
                    {
                       System.out.println("数据库异常被捕获了");
                       System.out.println(ex.getSQLState());
                       System.out.println(ex.getMessage());
                       System.out.println(ex.getErrorCode());
                       ex=ex.getNextException();
                    }

        	}
        }
       



public static void main(String args[])
{
   String l="jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=gw.mdb";
   String s="0";
   DataBaseManager db=new DataBaseManager(l);   
	String buf="BOX";
   String a=db.querySql(buf,"SMS","ID",s);
   System.out.println(a);
 
   


}

}