1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 package org.dbunit.operation;
23
24 import org.dbunit.DatabaseUnitException;
25 import org.dbunit.database.IDatabaseConnection;
26 import org.dbunit.dataset.IDataSet;
27
28 import java.sql.SQLException;
29
30
31
32
33
34
35
36
37 public abstract class DatabaseOperation
38 {
39 public static final DatabaseOperation NONE = new DummyOperation();
40 public static final DatabaseOperation UPDATE = new UpdateOperation();
41 public static final DatabaseOperation INSERT = new InsertOperation();
42 public static final DatabaseOperation REFRESH = new RefreshOperation();
43 public static final DatabaseOperation DELETE = new DeleteOperation();
44 public static final DatabaseOperation DELETE_ALL = new DeleteAllOperation();
45 public static final DatabaseOperation TRUNCATE_TABLE = new TruncateTableOperation();
46 public static final DatabaseOperation CLEAN_INSERT = new CompositeOperation(
47 DELETE_ALL, INSERT);
48 public static final DatabaseOperation TRANSACTION(DatabaseOperation operation) {
49 return new TransactionOperation(operation);
50 }
51 public static final DatabaseOperation CLOSE_CONNECTION(DatabaseOperation operation) {
52 return new CloseConnectionOperation(operation);
53 }
54
55
56
57
58
59
60
61
62 public abstract void execute(IDatabaseConnection connection,
63 IDataSet dataSet) throws DatabaseUnitException, SQLException;
64
65 private static class DummyOperation extends DatabaseOperation
66 {
67 public void execute(IDatabaseConnection connection, IDataSet dataSet)
68 {
69 }
70 }
71 }
72
73
74
75
76
77