001: /* Copyright (c) 1995-2000, The Hypersonic SQL Group.
002: * All rights reserved.
003: *
004: * Redistribution and use in source and binary forms, with or without
005: * modification, are permitted provided that the following conditions are met:
006: *
007: * Redistributions of source code must retain the above copyright notice, this
008: * list of conditions and the following disclaimer.
009: *
010: * Redistributions in binary form must reproduce the above copyright notice,
011: * this list of conditions and the following disclaimer in the documentation
012: * and/or other materials provided with the distribution.
013: *
014: * Neither the name of the Hypersonic SQL Group nor the names of its
015: * contributors may be used to endorse or promote products derived from this
016: * software without specific prior written permission.
017: *
018: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
019: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
020: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
021: * ARE DISCLAIMED. IN NO EVENT SHALL THE HYPERSONIC SQL GROUP,
022: * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
023: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
024: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
025: * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
026: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
027: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
028: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
029: *
030: * This software consists of voluntary contributions made by many individuals
031: * on behalf of the Hypersonic SQL Group.
032: *
033: *
034: * For work added by the HSQL Development Group:
035: *
036: * Copyright (c) 2001-2005, The HSQL Development Group
037: * All rights reserved.
038: *
039: * Redistribution and use in source and binary forms, with or without
040: * modification, are permitted provided that the following conditions are met:
041: *
042: * Redistributions of source code must retain the above copyright notice, this
043: * list of conditions and the following disclaimer.
044: *
045: * Redistributions in binary form must reproduce the above copyright notice,
046: * this list of conditions and the following disclaimer in the documentation
047: * and/or other materials provided with the distribution.
048: *
049: * Neither the name of the HSQL Development Group nor the names of its
050: * contributors may be used to endorse or promote products derived from this
051: * software without specific prior written permission.
052: *
053: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
054: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
055: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
056: * ARE DISCLAIMED. IN NO EVENT SHALL HSQL DEVELOPMENT GROUP, HSQLDB.ORG,
057: * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
058: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
059: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
060: * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
061: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
062: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
063: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
064: */
065:
066: package org.hsqldb;
067:
068: /**
069: * Represents a single row table operation.
070: *
071: * @author Thomas Mueller (Hypersonic SQL Group)
072: * @version 1.8.0
073: * @since Hypersonic SQL
074: */
075: class Transaction {
076:
077: boolean isDelete;
078: Table tTable;
079: Row row;
080: long SCN;
081:
082: /**
083: * Constructor. <p>
084: *
085: * @param delete if true, this represents a single row delete action, else
086: * a single row insert action
087: * @param nested true if this action is part of a transaction initiated
088: * within an INSERT INTO or UPDATE statement
089: * @param table the Table object against which the operation occured
090: * @param row the row data that iis inserted or deleted
091: */
092: Transaction(boolean delete, Table table, Row row, long SCN) {
093:
094: isDelete = delete;
095: tTable = table;
096: this .row = row;
097: }
098:
099: /**
100: * Undoes the single row delete or insert represented by this object.
101: *
102: * @param session the session context in which to perform the undo
103: * @param log if true log the work
104: * @throws HsqlException if a database access error occurs
105: */
106: void rollback(Session session, boolean log) {
107:
108: try {
109: if (isDelete) {
110: tTable.insertNoCheckRollback(session, row, log);
111: } else {
112: tTable.deleteNoCheckRollback(session, row, log);
113: }
114: } catch (Exception e) {
115:
116: // System.out.println("rollback error: isDelete " + isDelete);
117: }
118: }
119:
120: void commit(Session session) {
121:
122: try {
123: if (isDelete) {
124: tTable.removeRowFromStore(row);
125: } else {
126: tTable.commitRowToStore(row);
127: }
128: } catch (Exception e) {
129:
130: // System.out.println("rollback error: isDelete " + isDelete);
131: }
132: }
133:
134: void logRollback(Session session) {
135:
136: try {
137: if (isDelete) {
138: tTable.database.logger.writeInsertStatement(session,
139: tTable, row.getData());
140: } else {
141: tTable.database.logger.writeDeleteStatement(session,
142: tTable, row.getData());
143: }
144: } catch (Exception e) {
145: }
146: }
147:
148: void logAction(Session session) {
149:
150: try {
151: if (isDelete) {
152: tTable.database.logger.writeDeleteStatement(session,
153: tTable, row.getData());
154: } else {
155: tTable.database.logger.writeInsertStatement(session,
156: tTable, row.getData());
157: }
158: } catch (Exception e) {
159: }
160: }
161: }
|