myconnection.java

大学课程 数据库的课程设计

/*
 * MyConnection.java
 * 
 * Created on 2007-6-26, 15:25:51
 * 
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package t;

import java.sql.*;
import java.io.*;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Administrator
 */

public class MyConnection {
    Connection con ;
    String s="";
    static String a[][];
    static String a1[];
    int n;
    int b1;

    public MyConnection() {
       try     {
            java.lang.Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            con = java.sql.DriverManager.getConnection("jdbc:odbc:jipiaodatebase","", "");
        }
        catch (SQLException ex) {
    Logger.getLogger("global").log(Level.SEVERE, null, ex);
}
catch (ClassNotFoundException ex) {
            Logger.getLogger("global").log(Level.SEVERE, null, ex);
        }

    }
    
    public void myQuery(String s1,String s2)
    {
        try     {
            java.sql.Statement stmt = con.createStatement(java.sql.ResultSet.TYPE_SCROLL_SENSITIVE,
                                                          java.sql.ResultSet.CONCUR_READ_ONLY);
            ResultSet rs = stmt.executeQuery("select * from "+s+" where "+s1+"="+"'"+s2+"'");
           		rs.last();
			int b=rs.getRow();
			a  = new String[b][n];
			rs.beforeFirst();
			b=0;
			while(rs.next())
			{
				for(int i=0;i<n;i++)
				{
					a[b][i]=rs.getString(i+1);
				}
				b++;
			}
        }
        catch (SQLException ex) {
            Logger.getLogger("global").log(Level.SEVERE, null, ex);
        }

    }
    
    public void itemQuery(String s,String s1)
    {
        try     {
            java.sql.Statement stmt = con.createStatement(java.sql.ResultSet.TYPE_SCROLL_SENSITIVE,
                                                          java.sql.ResultSet.CONCUR_READ_ONLY);
             ResultSet rs = stmt.executeQuery("select "+s1+" from "+s);
             rs.last();
	     int b=rs.getRow();
             a1=new String [b];
             b1=b;
             rs.beforeFirst();
			b=0;
			while(rs.next())
			{
					a1[b]=rs.getString(1);
                                        b++;
			}
             
        }
        catch (SQLException ex) {
            Logger.getLogger("global").log(Level.SEVERE, null, ex);
        }
}
    
    public void setTablename(String s1)
    {
        s=s1;
    }
         
    public  void setNumber(int n1)
    {
        n=n1;
    }
    
    public void closeConnection()
    {
        try     {
            con.close();
        }
        catch (SQLException ex) {
            Logger.getLogger("global").log(Level.SEVERE, null, ex);
        }
}
    
    public String[][] getArray()
    {
        return a;
    }
    
    public String[] getItem()
    {
        return a1;
    }
    
    public int getItemNumber()
    {
        return b1;
    }
    
  
    public void insetAirLine(String s1,String s2)
    {
        try {
            java.sql.Statement stmt = con.createStatement();
            String st="insert into "+s1+" values ("+s2+")";
            stmt.executeUpdate(st);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    
    public void upDate(String s1,String s2,String s3)
    {
        try {
            java.sql.Statement stmt = con.createStatement();
            String st="update "+s1+" set "+s2+" where "+s3;
            stmt.executeUpdate(st);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    
    public void deleteInf(String s1,String s2)
    {
        try {
            java.sql.Statement stmt = con.createStatement();
            String st="delete * from "+s1+" where "+s2;
           // System.out.println(st);
            stmt.executeUpdate(st);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    
    public long getMaxAccount(String s,String s1)
    {
        long l=0;
        try {
            java.sql.Statement stmt = con.createStatement();
            ResultSet rs = stmt.executeQuery("select MAX("+s1+")"+" from "+s);
            while(rs.next())
                l=Integer.parseInt(rs.getString(1));
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return l;
    }
    
}