KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > hsqldb > scriptio > ScriptReaderBase


1 /* Copyright (c) 2001-2005, The HSQL Development Group
2  * All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions are met:
6  *
7  * Redistributions of source code must retain the above copyright notice, this
8  * list of conditions and the following disclaimer.
9  *
10  * Redistributions in binary form must reproduce the above copyright notice,
11  * this list of conditions and the following disclaimer in the documentation
12  * and/or other materials provided with the distribution.
13  *
14  * Neither the name of the HSQL Development Group nor the names of its
15  * contributors may be used to endorse or promote products derived from this
16  * software without specific prior written permission.
17  *
18  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
19  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21  * ARE DISCLAIMED. IN NO EVENT SHALL HSQL DEVELOPMENT GROUP, HSQLDB.ORG,
22  * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
23  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
24  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
25  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
26  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
27  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
28  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
29  */
30
31
32 package org.hsqldb.scriptio;
33
34 import java.io.IOException JavaDoc;
35
36 import org.hsqldb.Database;
37 import org.hsqldb.HsqlException;
38 import org.hsqldb.NumberSequence;
39 import org.hsqldb.Session;
40 import org.hsqldb.Table;
41
42 /**
43  * Base class for all script readers.
44  *
45  * @author fredt@users
46  * @version 1.7.2
47  * @since 1.7.2
48  */
49 public abstract class ScriptReaderBase {
50
51     public static ScriptReaderBase newScriptReader(Database db, String JavaDoc file,
52             int scriptType) throws HsqlException, IOException JavaDoc {
53
54         if (scriptType == ScriptWriterBase.SCRIPT_TEXT_170) {
55             return new ScriptReaderText(db, file);
56         } else if (scriptType == ScriptWriterBase.SCRIPT_BINARY_172) {
57             return new ScriptReaderBinary(db, file);
58         } else {
59             return new ScriptReaderZipped(db, file);
60         }
61     }
62
63     public static final int ANY_STATEMENT = 1;
64     public static final int DELETE_STATEMENT = 2;
65     public static final int INSERT_STATEMENT = 3;
66     public static final int SEQUENCE_STATEMENT = 4;
67     public static final int COMMIT_STATEMENT = 5;
68     public static final int SESSION_ID = 6;
69     public static final int SCHEMA_STATEMENT = 7;
70     Database db;
71     int lineCount;
72
73 // int byteCount;
74 String JavaDoc fileName;
75
76     ScriptReaderBase(Database db,
77                      String JavaDoc file) throws HsqlException, IOException JavaDoc {
78
79         this.db = db;
80         fileName = file;
81
82         openFile();
83     }
84
85     protected abstract void openFile() throws IOException JavaDoc;
86
87     public void readAll(Session session) throws IOException JavaDoc, HsqlException {
88         readDDL(session);
89         readExistingData(session);
90     }
91
92     protected abstract void readDDL(Session session)
93     throws IOException JavaDoc, HsqlException;
94
95     protected abstract void readExistingData(Session session)
96     throws IOException JavaDoc, HsqlException;
97
98     public abstract boolean readLoggedStatement(Session session)
99     throws IOException JavaDoc;
100
101     int statementType;
102     int sessionNumber;
103     Object JavaDoc[] rowData;
104     long sequenceValue;
105     String JavaDoc statement;
106     Table currentTable;
107     NumberSequence currentSequence;
108     String JavaDoc currentSchema;
109
110     public int getStatementType() {
111         return statementType;
112     }
113
114     public int getSessionNumber() {
115         return sessionNumber;
116     }
117
118     public Object JavaDoc[] getData() {
119         return rowData;
120     }
121
122     public String JavaDoc getLoggedStatement() {
123         return statement;
124     }
125
126     public NumberSequence getCurrentSequence() {
127         return currentSequence;
128     }
129
130     public long getSequenceValue() {
131         return sequenceValue;
132     }
133
134     public Table getCurrentTable() {
135         return currentTable;
136     }
137
138     public String JavaDoc getCurrentSchema() {
139         return currentSchema;
140     }
141
142     public int getLineNumber() {
143         return lineCount;
144     }
145
146     public abstract void close();
147 }
148
Popular Tags