Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.hsqldb.scriptio;
  
 
 public class ScriptReaderText extends ScriptReaderBase
 {
   boolean isInsert;
 
   ScriptReaderText(Database paramDatabaseString paramString)
     throws HsqlExceptionIOException
   {
     super(paramDatabaseparamString);
   }
 
   protected void openFile()
     throws IOException
   {
     InputStream localInputStream = this..isFilesInJar() ? getClass().getResourceAsStream(this.) : this..getFileAccess().openInputStreamElement(this.);
     this. = new BufferedReader(new InputStreamReader(new BufferedInputStream(localInputStream)));
   }
 
   protected void readDDL(Session paramSession)
     throws IOExceptionHsqlException
   {
     while (readLoggedStatement(paramSession))
       if (this..getStatementType() == 3)
       {
         this. = true;
       }
       else
       {
         Result localResult = paramSession.sqlExecuteDirectNoPreChecks(this.);
         if ((localResult == null) || (!localResult.isError()))
           continue;
         this....logContext(.localResult.getMainString());
         HsqlException localHsqlException = Trace.error(78, 113, new Object[] { new Integer(this.), localResult.getMainString() });
         throw localHsqlException;
       }
   }
 
   protected void readExistingData(Session paramSession)
     throws IOExceptionHsqlException
   {
     try
     {
       Object localObject = null;
       this..setReferentialIntegrity(false);
       while ((this.) || (readLoggedStatement(paramSession)))
       {
         if (this. == 7)
         {
           paramSession.setSchema(this.);
         }
         else if (this. == 3)
         {
           if (!this..getTableName().equals(localObject))
           {
             localObject = this..getTableName();
             String str = paramSession.getSchemaName(this.);
             this. = this...getUserTable(paramSession, (String)localObjectstr);
           }
           this..insertFromScript(this.);
         }
         this. = false;
       }
       this..setReferentialIntegrity(true);
     }
     catch (Exception localException)
     {
       this....logContext(localExceptionnull);
       throw Trace.error(78, 114, new Object[] { new Integer(this.), localException.toString() });
     }
   }
 
   public boolean readLoggedStatement(Session paramSession)
     throws IOException
   {
     String str = this..readLine();
     this. += 1;
     this. = StringConverter.asciiToUnicode(str);
     if (this. == null)
      return false;
    processStatement(paramSession);
    return true;
  }
  private void processStatement(Session paramSession)
    throws IOException
  {
    try
    {
      if (this..startsWith("/*C"))
      {
        int i = this..indexOf('*', 4);
        this. = Integer.parseInt(this..substring(3, i));
        this. = this..substring(i + 2);
      }
      this..setSource(this.);
      this. = this..getStatementType();
      if (this. == 1)
      {
        this. = null;
        this. = null;
        return;
      }
      if (this. == 5)
      {
        this. = null;
        this. = null;
        return;
      }
      if (this. == 7)
      {
        this. = null;
        this. = null;
        this. = this..getSchemaName();
        return;
      }
      String str1 = this..getTableName();
      String str2 = paramSession.getSchemaName(null);
      this. = this...getUserTable(paramSessionstr1str2);
      int[] arrayOfInt;
      if (this. == 3)
        arrayOfInt = this..getColumnTypes();
      else if (this..hasPrimaryKey())
        arrayOfInt = this..getPrimaryKeyTypes();
      else
        arrayOfInt = this..getColumnTypes();
      this. = this..readData(arrayOfInt);
    }
    catch (Exception localException)
    {
      throw new IOException(localException.toString());
    }
  }
  public void close()
  {
    try
    {
      this..close();
    }
    catch (Exception localException)
    {
    }
  }
/* Location:           /home/mnovotny/projects/EMBEDDED_JBOSS_BETA3_COMMUNITY/embedded/output/lib/embedded-jboss/lib/thirdparty-all.jar
 * Qualified Name:     org.hsqldb.scriptio.ScriptReaderText
 * JD-Core Version:    0.6.0
 */
New to GrepCode? Check out our FAQ X