Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.hsqldb.scriptio;
  
 
 {
   private RowInputBinary rowIn = new RowInputBinary();
   protected DataInputStream dataStreamIn;
 
   ScriptReaderBinary(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 DataInputStream(new BufferedInputStream(localInputStream, 8192));
   }
 
   protected void readDDL(Session paramSession)
     throws IOExceptionHsqlException
   {
     Result localResult1 = Result.read(this.this.);
     Iterator localIterator = localResult1.iterator();
     while (localIterator.hasNext())
     {
       Object[] arrayOfObject = (Object[])localIterator.next();
       String str = (String)arrayOfObject[0];
       Result localResult2 = paramSession.sqlExecuteDirectNoPreChecks(str);
       if (!localResult2.isError())
         continue;
       this....logContext(.localResult2.getMainString());
       throw Trace.error(localResult2);
     }
   }
 
   protected void readExistingData(Session paramSession)
     throws IOExceptionHsqlException
   {
     while (true)
     {
       String str1 = readTableInit();
       if (str1 == null)
         break;
       String str2 = paramSession.getSchemaName(this.);
       Table localTable = this...getUserTable(paramSessionstr1str2);
       int i = 0;
       for (i = 0; readRow(localTable); i++);
       int j = readTableTerm();
       if (i == j)
         continue;
       throw Trace.error(78, 96, new Object[] { str1new Integer(i), new Integer(j) });
     }
   }
 
   protected boolean readRow(Table paramTable)
     throws IOExceptionHsqlException
   {
     boolean bool = readRow(this., 0);
     if (!bool)
       return false;
     Object[] arrayOfObject = this..readData(paramTable.getColumnTypes());
     paramTable.insertFromScript(arrayOfObject);
     return true;
   }
 
   protected int readTableTerm()
     throws IOExceptionHsqlException
   {
     return this..readInt();
   }
 
   protected String readTableInit()
     throws IOExceptionHsqlException
   {
     boolean bool = readRow(this., 0);
     if (!bool)
       return null;
     String str = this..readString();
    int i = this..readIntData();
    if (i == 1)
      this. = this..readString();
    else
      this. = null;
    if ((i != 0) && (i != 1))
      throw Trace.error(78, 97);
    return str;
  }
  boolean readRow(RowInputBase paramRowInputBaseint paramInt)
    throws IOException
  {
    try
    {
      int i = this..readInt();
      int j = 4;
      if (i == 0)
        return false;
      paramRowInputBase.resetRow(paramInti);
      this..readFully(paramRowInputBase.getBuffer(), ji - j);
      return true;
    }
    catch (EOFException localEOFException)
    {
    }
    return false;
  }
  public boolean readLoggedStatement(Session paramSession)
    throws IOException
  {
    return false;
  }
  public void close()
  {
    try
    {
      this..close();
    }
    catch (IOException localIOException)
    {
    }
  }
/* Location:           /home/mnovotny/projects/EMBEDDED_JBOSS_BETA3_COMMUNITY/embedded/output/lib/embedded-jboss/lib/thirdparty-all.jar
 * Qualified Name:     org.hsqldb.scriptio.ScriptReaderBinary
 * JD-Core Version:    0.6.0
 */
New to GrepCode? Check out our FAQ X