Source code: mill/db/ORAconnect.java

   package mill.db;
   
   import java.sql.SQLException;
   import java.sql.PreparedStatement;
   import java.sql.ResultSet;
   import java.sql.DriverManager;
   import java.sql.Driver;
   import java.io.OutputStreamWriter;
   import java.io.FileOutputStream;
  
  import java.lang.Class;
  
  import java.util.Enumeration;
  
  import oracle.jdbc.driver.*;
  import oracle.sql.*;
  
  import mill.startup.InitJSPparam;
  
  //import mill.debug.Debug;
  
  /**
  Класс ORAconnect прденазначен для коннекта к оракловской базе данных.
  
  $Date: 28/09/2000 $
  */
  public class ORAconnect extends DBconnect
  {
  
      public boolean getIsClosed()
    throws SQLException
      {
    if (conn == null)
      return true;
    return conn.isClosed();
      }
  
      public int getMaxLengthStringField() {
    return 4000;
      }
  
      protected void finalize() throws Throwable
      {
    if ( isDynamicConnect )
    {
               try {
      conn.close();
      conn = null;
        }catch(Exception e){}
    }
    super.finalize();
      }
  
      public String getClobField(ResultSet rs, String nameField)
    throws SQLException
      {
    return getClobField(rs, nameField, 20000);
      }
  
      public String getClobField(ResultSet rs, String nameField, int maxLength)
    throws SQLException
      {
    CLOB clob = ((OracleResultSet)rs).getCLOB (nameField);
  
    if (clob==null)
      return null;
  
    return clob.getSubString(1, maxLength);
      }
  
    public long getSequenceNextValue( String s )
      throws SQLException
    {
      long id_ = -1;
  
          String sql_ = 
      "select "+ s.trim() + ".nextval from dual";
      PreparedStatement ps = null;
      ResultSet rs = null;
      try {
        ps = this.conn.prepareStatement( sql_ );
  
        rs = ps.executeQuery();
      
        if (rs.next())
                 id_ = rs.getLong(1);
  
      }
      finally
      {
        if (rs != null)
        {
          try {
            rs.close();
            rs = null;
          }
          catch(SQLException e){}
        }
        if (ps != null)
       {
         try {
           ps.close();
           ps = null;
         }
         catch(SQLException e1){}
       }
     }
 
     return id_;
   }
 
   public String getFirstValueString( String t, String f, String w, String o)
     throws SQLException
   {
 //    Debug db = new Debug();
 
     String id_ = null;
 
         String v_s = "select " + f + " from " + t;
 
         if (o != null) 
     {
       v_s += (w==null)? "": " "+w; 
             v_s += (" order by " + o);
     }
     else
     {
       v_s += (w==null)?
         "":
         " "+w+" and rownum<2 "; 
     }
 
 //    db.aM(v_s);
 
   
     PreparedStatement prepStatement = null;
     ResultSet rset = null;
     try {
       prepStatement = this.conn.prepareStatement(v_s);
 
       rset = prepStatement.executeQuery();
       
       if (rset.next())
                id_ = rset.getString(1);
 
     }
     finally
     {
       if (rset != null)
       {
         try {
           rset.close();
           rset = null;
         }
         catch(SQLException e){}
       }
       if (prepStatement != null)
       {
         try {
           prepStatement.close();
           prepStatement = null;
         }
         catch(SQLException e1){}
       }
     }
 
     return id_;
 
 //    return fromDB(id_);
   }
 
   public long getFirstValue( String t, String f, String w, String o)
     throws SQLException
   {
 //    Debug db = new Debug();
 
     long id_ = -1;
 
         String v_s = "select " + f + " from " + t;
 
         if (o != null) 
     {
       v_s += (w==null)? "": " "+w; 
             v_s += (" order by " + o);
     }
     else
     {
       v_s += (w==null)?
         "":
         " "+w+" and rownum<2 "; 
     }
 
 //    db.aM(v_s);
 
   
     PreparedStatement prepStatement = null;
     ResultSet rset = null;
     try {
       prepStatement = this.conn.prepareStatement(v_s);
 
       rset = prepStatement.executeQuery();
     
       if (rset.next())
                id_ = rset.getLong(1);
     }
     finally
     {
       if (rset != null)
       {
         try {
           rset.close();
           rset = null;
         }
         catch(SQLException e){}
       }
       if (prepStatement != null)
       {
         try {
           prepStatement.close();
           prepStatement = null;
         }
         catch(SQLException e1){}
       }
     }
 
     return id_;
   }
 
   public boolean testExceptionTableNotFound( Exception e )
   {
     
       if ((e instanceof SQLException) && 
       (e.toString().indexOf("ORA-00942") != -1))
     return true;
       return false;
   }
 
   public boolean testExceptionIndexUniqueKey( Exception e, String index)
   {
       if ((e instanceof SQLException) && 
         ((e.toString().indexOf("ORA-00001") != -1) && 
       (e.toString().indexOf(index) != -1)) )
 
       return true;
 
     return false;
         }
   
 
   public void nop()
   {
     int i = 0;
   }
 
 /**
 Этот метод создает коннект к серверу с указанным объектом типа ConnectionData.<br>
 
 Параметры:
 <blockquote>
 cd - объект типа mill.db.ConnectionData<br>
 </blockquote>
 */
     public ORAconnect(ConnectionData cd)
   throws Exception
     {
   if (cd == null)
     throw new SQLException("#21.001: ConnectionData data not initialized.");
 
   if (!isDriverLoaded)
   {
       Class cl_ = Class.forName ( "oracle.jdbc.driver.OracleDriver" );
       isDriverLoaded = true;
   }
 
   conn = (OracleConnection)DriverManager.getConnection
   ("jdbc:oracle:thin:@" + cd.host, cd.login, cd.pass);
 
   conn.setAutoCommit (cd.isCommit);
 
      }
 
 
     public ORAconnect()
   throws Exception
     {
   this( getConnectionData() );
     }
 
 }