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
{
  Connection con;
       ResultSet rs;  
  Statement stmt;
        
        //String search_str=subString(s);
    
    /*为数据库管理器的构造函数,进行数据库链接*/
       public DataBaseManager(String l,String user,String password)
  {
            
        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,user,password);
              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)
     {
       Des des=new Des("12345678");
       System.out.println("加密前的字符串"+s); 
       String search_str=des.enc(s,s.length()); 
       byte[] tempstr=search_str.getBytes();
       String q_Str=byte2hex(tempstr);
       System.out.println("加密后的二进制字符串"+q_Str);
           String s_buf=sbuf;
       String tab=table;
       String strSQL="select * from "+tab+" where "+s_buf+"="+"\'"+q_Str+"\'";
           //String temp="%"+search_str+"%";    
       //String strSQL="select * from titles where pub_id like '"+temp+"'";  
       System.out.println(strSQL);
       try
       {
         rs=stmt.executeQuery(strSQL);
         rs.next();
         String tempre=rs.getString(buf).trim();
         System.out.println("找到的二进制串"+tempre+"iddd");
         byte[] re=hex2byte(tempre);
         String re1=new String(re);
         System.out.println(re1);
         String result=des.dec(re1,re1.length());
         System.out.println("解密后的字符串"+result);
         return result;
         //System.out.println("This is content "+rs.getString(buf));
       }
         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("未找到指定记录");
                    }
        return null;
          }
  
       }

        public boolean updateSql(String table,String buf,String s,String ubuf,String us)
        {
      Des des=new Des("12345678");
      System.out.println("加密前要查找的字符串"+s); 
      System.out.println("加密前要写入的字符串"+us);
      String search_str=des.enc(s,s.length()); 
      String search_ustr=des.enc(us,us.length());
      System.out.println("wu的加密字符"+search_ustr);
System.out.println("wu的加密字符"+des.dec(search_ustr,search_ustr.length()));
      byte[] tempstr=search_str.getBytes();
      byte[] tempustr=search_ustr.getBytes();
      String q_Str=byte2hex(tempstr);
      System.out.println("加密后的要查找的二进制字符串"+q_Str);
      String u_Str=byte2hex(tempustr);
      System.out.println("加密后的要写入的二进制字符串"+u_Str+"i am is girl");
        String tab=table;
      String temp=search_str;  
      String strSQL="update "+tab+" set "+ubuf+"="+"\'"+u_Str+"\'"+" where "+buf+"="+"\'"+q_Str+"\'";
      //String strSQL="update "+tab+" set "+ubuf+"="+"\'"+us+"\'"+" where "+buf+"="+"\'"+temp+"\'";
      System.out.println(strSQL);
          try{
        stmt.executeUpdate(strSQL);
        con.commit();
        System.out.println("写入成功");
                return true;
          
                 }
        catch(SQLException sqle)
               {
          System.out.println(sqle.toString());
          return false;
                 }
        
        }
       // public Vector additems

  public boolean insertSql(String table,String buf,String s)
  {
    Des des=new Des("12345678");
    System.out.println("加密前的二进制串"+s);
    String write_Str=des.enc(s,s.length());
    byte[] str=write_Str.getBytes();
    String w_Str=byte2hex(str);
    System.out.println("加密后的二进制串"+w_Str);
    String tab=table;
    String write_buf=buf;
    String strSQL="INSERT INTO "+tab+" ("+write_buf+") "+" values "+" ("+"\'"+w_Str+"\'"+")";
    //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;
    }

  }
  

/**
* 二进制转字符串。
* 
* @param b
* @return
*/
private String byte2hex(byte[] b)
{
String hs = "";
String stmp = "";
for (int n = 0; n < b.length; n++)
{
stmp = (java.lang.Integer.toHexString(b[n] & 0XFF));
if (stmp.length() == 1)
hs = hs + "0" + stmp;
else
hs = hs + stmp;
if (n < b.length - 1)
hs = hs + ":";
}
return hs.toUpperCase();
}

/**
* 字符串转二进制。
* 
* @param hex
* @return
*/
private byte[] hex2byte(String hex)
{
String[] h = hex.split(":");
byte[] b = new byte[h.length];
for (int i = 0; i < h.length; i++)
{
int byteint = Integer.parseInt(h[i], 16) & 0xFF;
b[i] = new Integer(byteint).byteValue();
}
return b;
}

/**
* @return Returns the algorithm.
*/

/**
* @param algorithm
* The algorithm to set.

  /*断开与数据库的链接*/
        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:fangwei";
   String s="20";
   DataBaseManager db=new DataBaseManager(l,"sa","kelly");  
   String buf="Product_sn";  
   boolean x=db.insertSql("server1","Product_sn","20");
boolean y=db.updateSql("server1","Product_sn","20","Product_area","wu");
  String a=db.querySql("Product_area","server1","Product_sn",s);

  System.out.println("找到的"+a);
   //boolean y=db.updateSql("server","Product_sn","?abcd","Product_area","wu");
 //a=db.querySql(buf,"server","Product_sn",s);

 //  System.out.println(a);
  db.closeConnection();
   

}

}