00001
package com.quadcap.sql;
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039
00040
00041
import java.io.Externalizable;
00042
import java.io.IOException;
00043
import java.io.ObjectInput;
00044
import java.io.ObjectOutput;
00045
import java.io.OutputStream;
00046
00047
import java.sql.SQLException;
00048
00049
import com.quadcap.util.Debug;
00050
import com.quadcap.sql.io.Extern;
00051
00052
00053
00054
00055
00056
00057 public class AddTable extends LogStep implements
Externalizable {
00058 Relation table;
00059
00060
00061
00062
00063 public AddTable() {}
00064
00065
00066
00067
00068 public AddTable(
Session session,
Relation table) {
00069 super(session);
00070
this.table = table;
00071 }
00072
00073
00074
00075
00076 public void redo(
Session session)
throws IOException, SQLException {
00077
Database db = session.getDatabase();
00078 db.
addRelation(
table);
00079 }
00080
00081
00082
00083
00084 public void undo(
Session session)
throws IOException, SQLException {
00085
Database db = session.getDatabase();
00086 db.
removeRelation(
table.
getName());
00087 }
00088
00089
00090
00091
00092
00093
00094 public void prepare(
Session session)
throws IOException, SQLException {
00095
Database db = session.getDatabase();
00096
if (db.
getRelation(
table.
getName()) != null) {
00097
throw new SQLException(
"Table/view already exists: " +
00098
table.
getName(),
00099
"42000");
00100 }
00101 }
00102
00103
00104
00105
00106 public void readExternal(ObjectInput in)
00107
throws IOException, ClassNotFoundException
00108 {
00109 super.readExternal(in);
00110
table = (
Relation)in.readObject();
00111 }
00112
00113
00114
00115
00116 public void writeExternal(ObjectOutput out)
throws IOException {
00117 super.writeExternal(out);
00118 out.writeObject(
table);
00119 }
00120
00121
00122
00123
00124
00125 public String
toString() {
00126 StringBuffer sb =
new StringBuffer(super.toString());
00127 sb.append(
" AddTable(");
00128 sb.append(
table.toString());
00129 sb.append(
')');
00130
return sb.toString();
00131 }
00132
00133
00134 static Extern
extern;
00135 public void setExtern(Extern
extern) {
AddTable.extern =
extern; }
00136 public Extern
getExtern() {
return extern; }
00137 }