|
1 package com.daffodilwoods.daffodildb.server.sql99.ddl.descriptors;
2
3 import com.daffodilwoods.daffodildb.server.datadictionarysystem.*;
4 import com.daffodilwoods.daffodildb.server.serversystem.*;
5 import com.daffodilwoods.daffodildb.server.sql99.*;
6 import com.daffodilwoods.daffodildb.server.sql99.dql.iterator.*;
7 import com.daffodilwoods.database.general.*;
8 import com.daffodilwoods.database.resource.*;
9
10 public class SqlSchemaConstants extends SystemTables {
11 public static final String  defaultCatalog = "users";
12 public static final String defaultSchema = "users";
13 public static final String defaultCharacterSet = "SQLLanguageCharacter";
14 public static final String defaultCountryCode = "US";
15 public static final String defaultLanguageCode = "en";
16
17 public static final String systemCatalog = "system";
18
19
20 public static final String baseTableType = "Base Table";
21 public static final String viewTableType = "View";
22 public static final String indexTableType = "Index Table";
23 public static final String globalTemporaryTableType = "Global Temporary";
24 public static final String localTemporaryTableType = "Local Temporary";
25 public static final String deleteCommitAction = "Delete";
26 public static final String preserveCommitAction = "Preserve";
27
28 public static final String NO = "NO";
29 public static final String YES = "YES";
30
31 public static final String ForeignKey = "Foreign Key";
32 public static final String PrimaryKey = "Primary Key";
33
34 public static final String UdfType = "User Defined";
35 public static final String RefType = "Ref";
36 public static final String CollectionType = "Collection";
37 public static final String RowType = "Row Type";
38 public static final String BitVaryingType = "Bit Varying";
39 public static final String IntervalType = "Interval";
40 public static final String NoAction = "No Action";
41 public static final String dateSpanFrom = "__from";
42 public static final String dateSpanTo = "__to";
43 public static final String restrict = "restrict";
44
45 public static _SelectQueryIterator getIterator(_ServerSession serverSession,
46 String clause, Object [] parameters) throws DException {
47 if (parameters == null) {
48 return (_SelectQueryIterator) serverSession.getGlobalSession().executeQuery(clause, 0);
49 }
50 _Executer executer = (_Executer) serverSession.getGlobalSession().
51 executeQueryParameterised(clause, 0);
52 return (_SelectQueryIterator) executer.execute(parameters);
53 }
54
55 public static _Executer getExecuter(_ServerSession serverSession,
56 String clause) throws DException {
57 return (_Executer) serverSession.getGlobalSession().
58 executeQueryParameterised(clause, 0);
59 }
60
61 public static _SelectQueryIterator getIteratorOnCurrent(_ServerSession serverSession,
62 String clause, Object [] parameters) throws DException {
63 if (parameters == null) {
64 return (_SelectQueryIterator) serverSession.executeQuery(clause, 0);
65 }
66 _Executer executer = (_Executer) serverSession.executeQueryParameterised(clause, 0);
67 return (_SelectQueryIterator) executer.execute(parameters);
68 }
69
70 public static void insert(_ServerSession serverSession, QualifiedIdentifier tableName,
71 int[] indexes, Object [] columns) throws DException {
72 _ServerTable serverTable = serverSession.getSystemServerSession().getServerTable(tableName);
73 serverTable.insert(indexes, columns);
74 }
75
76 public static void delete(_ServerSession systemSession,
77 QualifiedIdentifier tableName, _Iterator iter) throws DException {
78 _ServerTable serverTable = systemSession.getServerTable(tableName);
79
80 if (!iter.first()) {
81 iter.first();
82 throw new DException("DSE841", null);
83 }
84 serverTable.delete(iter);
85 }
86
87 public static void deleteAll(_ServerSession systemSession,
88 QualifiedIdentifier tableName, _Iterator iter) throws
89 DException {
90 _ServerTable serverTable = systemSession.getServerTable(tableName);
91 if (iter.first()) {
92 do {
93 serverTable.delete(iter);
94 } while (iter.next());
95 }
96 }
97
98 public static void update(_ServerSession systemSession,
99 QualifiedIdentifier tableName, _Iterator iter,
100 int[] index, Object [] columnValue) throws
101 DException {
102
103 if (!iter.first()) {
104 throw new DException("DSE841", null);
105 }
106 if (index != null) {
107 for (int i = 0; i < index.length; i++) {
108 index[i] = SystemFields.systemFieldsCount + index[i] -
109 SystemTablesFields.systemFieldsCount;
110 }
111 }
112 _ServerTable serverTable = systemSession.getServerTable(tableName);
113 serverTable.update(iter, index, columnValue);
114 }
115 }
116 |
Popular Tags |
Java API By Example, From Geeks To Geeks.