public class Tables
extends java.lang.Object
implements java.lang.Iterable<java.lang.String>
Modifier and Type | Class and Description |
---|---|
static class |
Tables.Data |
class |
Tables.HeapRowIterator |
class |
Tables.OrderedRowIterator |
class |
Tables.Row |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentHashMap<java.lang.String,TablesColumnIndex> |
cidx |
private static java.lang.String |
CIDX |
private int |
keymaxlen |
private java.io.File |
location |
private static GenericFormatter |
my_SHORT_MILSEC_FORMATTER |
private static int |
NOINDEX |
private static java.lang.String |
p1 |
private static java.lang.String |
p2 |
private static java.lang.String |
p3 |
private static int |
RAMINDEX |
private static java.lang.String |
suffix |
private static java.lang.String |
system_table_pkcounter |
private static java.lang.String |
system_table_pkcounter_counterName |
private java.util.concurrent.ConcurrentHashMap<java.lang.String,BEncodedHeap> |
tables |
Constructor and Description |
---|
Tables(java.io.File location,
int keymaxlen) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
clear(java.lang.String tablename) |
void |
close() |
void |
close(java.lang.String tablename) |
java.util.ArrayList<java.lang.String> |
columns(java.lang.String table) |
byte[] |
createRow(java.lang.String table) |
void |
delete(java.lang.String table,
byte[] pk) |
java.util.Iterator<Tables.Row> |
getByIndex(java.lang.String table,
java.lang.String whereColumn,
java.lang.String separator,
java.lang.String whereValue) |
BEncodedHeap |
getHeap(java.lang.String tablename) |
TablesColumnIndex |
getIndex(java.lang.String tableName) |
TablesColumnIndex |
getIndex(java.lang.String tableName,
TablesColumnIndex.INDEXTYPE indexType) |
java.util.Set<java.lang.String> |
getTablenames() |
boolean |
has(java.lang.String table,
byte[] key) |
boolean |
hasHeap(java.lang.String tablename) |
boolean |
hasIndex(java.lang.String tableName) |
boolean |
hasIndex(java.lang.String tableName,
java.lang.String columnName) |
void |
insert(java.lang.String table,
byte[] pk,
java.util.Map<java.lang.String,byte[]> map) |
byte[] |
insert(java.lang.String tablename,
java.util.Map<java.lang.String,byte[]> map)
insert a map into a table using a new unique key
|
void |
insert(java.lang.String table,
Tables.Row row) |
private java.lang.String |
int2key(int i) |
java.util.Iterator<java.lang.String> |
iterator() |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
boolean up) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
java.util.regex.Pattern wherePattern) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
java.util.regex.Pattern wherePattern,
boolean up) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
java.lang.String whereColumn,
byte[] whereValue) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
java.lang.String whereColumn,
byte[] whereValue,
boolean up) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
java.lang.String whereColumn,
java.util.regex.Pattern wherePattern) |
java.util.Iterator<Tables.Row> |
iterator(java.lang.String table,
java.lang.String whereColumn,
java.util.regex.Pattern wherePattern,
boolean up) |
java.util.Iterator<byte[]> |
keys(java.lang.String table) |
java.util.Iterator<byte[]> |
keys(java.lang.String table,
boolean up,
boolean rotating) |
static void |
main(java.lang.String[] args) |
static java.util.Collection<Tables.Row> |
orderBy(java.util.Iterator<Tables.Row> rowIterator,
int maxcount,
java.lang.String sortColumn) |
Tables.Row |
select(java.lang.String table,
byte[] pk) |
int |
size()
get the total number of known tables
|
int |
size(java.lang.String table) |
private byte[] |
ukey(java.lang.String tablename) |
void |
update(java.lang.String table,
byte[] pk,
java.util.Map<java.lang.String,byte[]> map) |
void |
update(java.lang.String table,
Tables.Row row) |
private static final java.lang.String p1
private static final java.lang.String p2
private static final java.lang.String p3
private static final java.lang.String CIDX
private static final int NOINDEX
private static final int RAMINDEX
private static final java.lang.String suffix
private static final java.lang.String system_table_pkcounter
private static final java.lang.String system_table_pkcounter_counterName
private final java.io.File location
private final java.util.concurrent.ConcurrentHashMap<java.lang.String,BEncodedHeap> tables
private final java.util.concurrent.ConcurrentHashMap<java.lang.String,TablesColumnIndex> cidx
private int keymaxlen
private static final GenericFormatter my_SHORT_MILSEC_FORMATTER
public TablesColumnIndex getIndex(java.lang.String tableName, TablesColumnIndex.INDEXTYPE indexType) throws TableColumnIndexException, java.io.IOException
TableColumnIndexException
java.io.IOException
public TablesColumnIndex getIndex(java.lang.String tableName) throws TableColumnIndexException
TableColumnIndexException
public boolean hasIndex(java.lang.String tableName)
public boolean hasIndex(java.lang.String tableName, java.lang.String columnName)
public java.util.Iterator<Tables.Row> getByIndex(java.lang.String table, java.lang.String whereColumn, java.lang.String separator, java.lang.String whereValue)
public java.util.Iterator<java.lang.String> iterator()
iterator
in interface java.lang.Iterable<java.lang.String>
public java.util.Set<java.lang.String> getTablenames()
public void close(java.lang.String tablename)
public void close()
public void clear()
public void clear(java.lang.String tablename)
public boolean hasHeap(java.lang.String tablename)
public BEncodedHeap getHeap(java.lang.String tablename) throws java.io.IOException
java.io.IOException
public int size()
public int size(java.lang.String table) throws java.io.IOException
java.io.IOException
private byte[] ukey(java.lang.String tablename) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
private java.lang.String int2key(int i)
public byte[] insert(java.lang.String tablename, java.util.Map<java.lang.String,byte[]> map) throws java.io.IOException, SpaceExceededException
tablename
- map
- SpaceExceededException
java.io.IOException
SpaceExceededException
public void insert(java.lang.String table, byte[] pk, java.util.Map<java.lang.String,byte[]> map) throws java.io.IOException
java.io.IOException
public void insert(java.lang.String table, Tables.Row row) throws java.io.IOException
java.io.IOException
public void update(java.lang.String table, byte[] pk, java.util.Map<java.lang.String,byte[]> map) throws java.io.IOException
java.io.IOException
public void update(java.lang.String table, Tables.Row row) throws java.io.IOException
java.io.IOException
public byte[] createRow(java.lang.String table) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
public Tables.Row select(java.lang.String table, byte[] pk) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
public void delete(java.lang.String table, byte[] pk) throws java.io.IOException
java.io.IOException
public boolean has(java.lang.String table, byte[] key) throws java.io.IOException
java.io.IOException
public java.util.Iterator<byte[]> keys(java.lang.String table) throws java.io.IOException
java.io.IOException
public java.util.Iterator<byte[]> keys(java.lang.String table, boolean up, boolean rotating) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, java.lang.String whereColumn, byte[] whereValue) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, java.lang.String whereColumn, java.util.regex.Pattern wherePattern) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, java.util.regex.Pattern wherePattern) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, boolean up) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, java.lang.String whereColumn, byte[] whereValue, boolean up) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, java.lang.String whereColumn, java.util.regex.Pattern wherePattern, boolean up) throws java.io.IOException
java.io.IOException
public java.util.Iterator<Tables.Row> iterator(java.lang.String table, java.util.regex.Pattern wherePattern, boolean up) throws java.io.IOException
java.io.IOException
public static java.util.Collection<Tables.Row> orderBy(java.util.Iterator<Tables.Row> rowIterator, int maxcount, java.lang.String sortColumn)
public java.util.ArrayList<java.lang.String> columns(java.lang.String table) throws java.io.IOException
java.io.IOException
public static void main(java.lang.String[] args)