Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.hsqldb.scriptio;
  
  import org.hsqldb.Session;
 
 public class ScriptWriterText extends ScriptWriterBase
 {
   public static final byte[] BYTES_LINE_SEP;
   static final byte[] BYTES_COMMIT;
   static final byte[] BYTES_INSERT_INTO;
   static final byte[] BYTES_VALUES;
   static final byte[] BYTES_TERM;
   static final byte[] BYTES_DELETE_FROM;
   static final byte[] BYTES_WHERE;
   static final byte[] BYTES_SEQUENCE;
   static final byte[] BYTES_SEQUENCE_MID;
   static final byte[] BYTES_C_ID_INIT;
   static final byte[] BYTES_C_ID_TERM;
   static final byte[] BYTES_SCHEMA;
 
   {
   }
 
   public ScriptWriterText(Database paramDatabaseString paramStringboolean paramBoolean1boolean paramBoolean2boolean paramBoolean3)
     throws HsqlException
   {
     super(paramDatabaseparamStringparamBoolean1paramBoolean2paramBoolean3);
   }
 
   protected void initBuffers()
   {
     this. = new RowOutputTextLog();
   }
 
   protected void writeDataTerm()
     throws IOException
   {
   }
 
   protected void addSessionId(Session paramSession)
     throws IOException
   {
     if (paramSession == null)
       return;
     if (paramSession != this.)
     {
       this..write();
       this..writeIntData(paramSession.getId());
       this..write();
       this. = paramSession;
     }
     if (this. != paramSession.loggedSchema)
     {
       writeSchemaStatement(this.);
       paramSession.loggedSchema = this.;
     }
   }
 
   private void writeSchemaStatement(HsqlNameManager.HsqlName paramHsqlName)
   {
     this..write();
     this..writeString(paramHsqlName.statementName);
     this..write();
   }
 
   public void writeLogStatement(Session paramSessionString paramString)
     throws IOExceptionHsqlException
   {
     this. = paramSession.currentSchema;
     this. = true;
     this..reset();
     addSessionId(paramSession);
     this..writeString(paramString);
     this..write();
     this..write(this..getBuffer(), 0, this..size());
     this. += this..size();
     this. = true;
     this. = false;
     if ((this.) || (this. == 0))
       sync();
   }
 
   protected void writeRow(Session paramSessionTable paramTableObject[] paramArrayOfObject)
     throws HsqlExceptionIOException
   {
     this. = true;
     this..reset();
     this..setMode(0);
     addSessionId(paramSession);
    this..writeString(paramTable.getName().);
    this..writeData(paramArrayOfObjectparamTable);
    this..write();
    this..write(this..getBuffer(), 0, this..size());
    this. += this..size();
    this. |= paramSession.isAutoCommit();
    this. = false;
    if ((this.) || (this. == 0))
      sync();
  }
  protected void writeTableInit(Table paramTable)
    throws HsqlExceptionIOException
  {
    if (paramTable.isEmpty(this.))
      return;
    if (this. == this..)
      return;
    this..reset();
    writeSchemaStatement(paramTable.getName().);
    this..write(this..getBuffer(), 0, this..size());
  }
  public void writeInsertStatement(Session paramSessionTable paramTableObject[] paramArrayOfObject)
    throws HsqlExceptionIOException
  {
    this. = paramTable.getName().;
    writeRow(paramSessionparamTableparamArrayOfObject);
  }
  public void writeDeleteStatement(Session paramSessionTable paramTableObject[] paramArrayOfObject)
    throws HsqlExceptionIOException
  {
    this. = paramTable.getName().;
    this. = true;
    this..reset();
    this..setMode(1);
    addSessionId(paramSession);
    this..writeString(paramTable.getName().);
    this..write();
    this..writeData(paramTable.getColumnCount(), paramTable.getColumnTypes(), paramArrayOfObjectparamTable.columnListparamTable.getPrimaryKey());
    this..write(this..getBuffer(), 0, this..size());
    this. += this..size();
    this. |= paramSession.isAutoCommit();
    this. = false;
    if ((this.) || (this. == 0))
      sync();
  }
  public void writeSequenceStatement(Session paramSessionNumberSequence paramNumberSequence)
    throws HsqlExceptionIOException
  {
    this. = paramNumberSequence.getName().;
    this. = true;
    this..reset();
    addSessionId(paramSession);
    this..writeString(paramNumberSequence.getName().);
    this..writeLongData(paramNumberSequence.peek());
    this..write(this..getBuffer(), 0, this..size());
    this. += this..size();
    this. = true;
    this. = false;
    if ((this.) || (this. == 0))
      sync();
  }
  public void writeCommitStatement(Session paramSession)
    throws HsqlExceptionIOException
  {
    this. = true;
    this..reset();
    addSessionId(paramSession);
    this..write(this..getBuffer(), 0, this..size());
    this. += this..size();
    this. = true;
    this. = false;
    if ((this.) || (this. == 0))
      sync();
  }
  protected void finalize()
  {
    sync();
  }
  static
  {
    String str = System.getProperty("line.separator""\n");
     = str.getBytes();
     = "COMMIT".getBytes();
     = "INSERT INTO ".getBytes();
     = " VALUES(".getBytes();
     = ")".getBytes();
     = "DELETE FROM ".getBytes();
     = " WHERE ".getBytes();
     = "ALTER SEQUENCE ".getBytes();
     = " RESTART WITH ".getBytes();
     = "/*C".getBytes();
     = "*/".getBytes();
     = "SET SCHEMA ".getBytes();
  }
/* Location:           /home/mnovotny/projects/EMBEDDED_JBOSS_BETA3_COMMUNITY/embedded/output/lib/embedded-jboss/lib/thirdparty-all.jar
 * Qualified Name:     org.hsqldb.scriptio.ScriptWriterText
 * JD-Core Version:    0.6.0
 */
New to GrepCode? Check out our FAQ X