00001
package com.quadcap.sql.meta;
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.IOException;
00042
00043
import java.util.HashMap;
00044
import java.util.Iterator;
00045
import java.util.Vector;
00046
00047
import java.sql.DatabaseMetaData;
00048
import java.sql.SQLException;
00049
00050
import com.quadcap.sql.Column;
00051
import com.quadcap.sql.Database;
00052
import com.quadcap.sql.Row;
00053
import com.quadcap.sql.Session;
00054
00055
import com.quadcap.sql.index.Btree;
00056
import com.quadcap.sql.index.BCursor;
00057
00058
import com.quadcap.sql.types.*;
00059
00060
import com.quadcap.util.Debug;
00061
00062
00063
00064
00065
00066
00067 public class MetaSchemas extends MetaCursor {
00068 static Column[]
cols = {
00069
new Column(
"TABLE_SCHEM", typeString)
00070 };
00071
00072 static int[]
sortColumns = { 1 };
00073
00074
00075
00076
00077 public MetaSchemas(
Session session)
00078
throws SQLException
00079 {
00080 super(session, null);
00081
try {
00082 addColumns(
cols);
00083 HashMap schemaNames =
new HashMap();
00084
Database db = session.
getDatabase();
00085 session.
getTableWriteLock(
"#Schema");
00086
synchronized (db.getFile().getLock()) {
00087 Iterator iter = db.
getRelationNameIterator();
00088
while (iter.hasNext()) {
00089 String name = iter.next().toString();
00090
int idx = name.indexOf(
'.');
00091
if (idx > 0) {
00092 name = name.substring(0, idx);
00093 }
else {
00094 name = session.
getConnection().
getAuth();
00095 }
00096
if (!schemaNames.containsKey(name)) {
00097
Row row =
new Row(1);
00098 row.
set(1,
new ValueString(name));
00099 addRow(row);
00100 schemaNames.put(name,
"");
00101 }
00102 }
00103 }
00104
sort();
00105 }
catch (
ValueException e) {
00106
Debug.print(e);
00107 SQLException te =
new SQLException(e.toString(),
"Q000P");
00108 te.setNextException(e);
00109
throw te;
00110 }
catch (IOException e) {
00111
Debug.print(e);
00112
throw new SQLException(e.toString(),
"Q000Q");
00113 }
00114 }
00115
00116
00117
00118
00119 public int[]
getSortColumns() {
00120
return sortColumns;
00121 }
00122 }