|
|
@@ -0,0 +1,237 @@
|
|
|
+package org.mjdev.tvlib.helpers.cursor;
|
|
|
+
|
|
|
+import android.database.AbstractCursor;
|
|
|
+import android.database.Cursor;
|
|
|
+import android.database.CursorIndexOutOfBoundsException;
|
|
|
+
|
|
|
+import java.util.ArrayList;
|
|
|
+
|
|
|
+public class MatrixCursor extends AbstractCursor {
|
|
|
+
|
|
|
+ private final String[] columnNames;
|
|
|
+ private Object[] data;
|
|
|
+ private int rowCount = 0;
|
|
|
+ private final int columnCount;
|
|
|
+
|
|
|
+ public MatrixCursor(String[] columnNames, int initialCapacity) {
|
|
|
+ this.columnNames = columnNames;
|
|
|
+ this.columnCount = columnNames.length;
|
|
|
+ if (initialCapacity < 1) {
|
|
|
+ initialCapacity = 1;
|
|
|
+ }
|
|
|
+ this.data = new Object[columnCount * initialCapacity];
|
|
|
+ }
|
|
|
+
|
|
|
+ public MatrixCursor(String[] columnNames) {
|
|
|
+ this(columnNames, 16);
|
|
|
+ }
|
|
|
+
|
|
|
+ private Object get(int column) {
|
|
|
+ if (column < 0 || column >= columnCount) {
|
|
|
+ throw new CursorIndexOutOfBoundsException("Requested column: "
|
|
|
+ + column + ", # of columns: " + columnCount);
|
|
|
+ }
|
|
|
+ if (mPos < 0) {
|
|
|
+ throw new CursorIndexOutOfBoundsException("Before first row.");
|
|
|
+ }
|
|
|
+ if (mPos >= rowCount) {
|
|
|
+ throw new CursorIndexOutOfBoundsException("After last row.");
|
|
|
+ }
|
|
|
+ return data[mPos * columnCount + column];
|
|
|
+ }
|
|
|
+
|
|
|
+ public void clear() {
|
|
|
+ data = new Object[0];
|
|
|
+ }
|
|
|
+
|
|
|
+ public RowBuilder newRow() {
|
|
|
+ final int row = rowCount++;
|
|
|
+ final int endIndex = rowCount * columnCount;
|
|
|
+ ensureCapacity(endIndex);
|
|
|
+ return new RowBuilder(row);
|
|
|
+ }
|
|
|
+
|
|
|
+ public void addRow(Object[] columnValues) {
|
|
|
+ if (columnValues.length != columnCount) {
|
|
|
+ throw new IllegalArgumentException("columnNames.length = "
|
|
|
+ + columnCount + ", columnValues.length = "
|
|
|
+ + columnValues.length);
|
|
|
+ }
|
|
|
+ int start = rowCount++ * columnCount;
|
|
|
+ ensureCapacity(start + columnCount);
|
|
|
+ System.arraycopy(columnValues, 0, data, start, columnCount);
|
|
|
+ }
|
|
|
+
|
|
|
+ public void addRow(Iterable<?> columnValues) {
|
|
|
+ int start = rowCount * columnCount;
|
|
|
+ int end = start + columnCount;
|
|
|
+ ensureCapacity(end);
|
|
|
+ if (columnValues instanceof ArrayList<?>) {
|
|
|
+ addRow((ArrayList<?>) columnValues, start);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ int current = start;
|
|
|
+ Object[] localData = data;
|
|
|
+ for (Object columnValue : columnValues) {
|
|
|
+ if (current == end) {
|
|
|
+ throw new IllegalArgumentException(
|
|
|
+ "columnValues.size() > columnNames.length");
|
|
|
+ }
|
|
|
+ localData[current++] = columnValue;
|
|
|
+ }
|
|
|
+ if (current != end) {
|
|
|
+ throw new IllegalArgumentException(
|
|
|
+ "columnValues.size() < columnNames.length");
|
|
|
+ }
|
|
|
+ rowCount++;
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addRow(ArrayList<?> columnValues, int start) {
|
|
|
+ int size = columnValues.size();
|
|
|
+ if (size != columnCount) {
|
|
|
+ throw new IllegalArgumentException("columnNames.length = "
|
|
|
+ + columnCount + ", columnValues.size() = " + size);
|
|
|
+ }
|
|
|
+ rowCount++;
|
|
|
+ Object[] localData = data;
|
|
|
+ for (int i = 0; i < size; i++) {
|
|
|
+ localData[start + i] = columnValues.get(i);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void ensureCapacity(int size) {
|
|
|
+ if (size > data.length) {
|
|
|
+ Object[] oldData = this.data;
|
|
|
+ int newSize = data.length * 2;
|
|
|
+ if (newSize < size) {
|
|
|
+ newSize = size;
|
|
|
+ }
|
|
|
+ this.data = new Object[newSize];
|
|
|
+ System.arraycopy(oldData, 0, this.data, 0, oldData.length);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public class RowBuilder {
|
|
|
+ private final int row;
|
|
|
+ private final int endIndex;
|
|
|
+
|
|
|
+ private int index;
|
|
|
+
|
|
|
+ RowBuilder(int row) {
|
|
|
+ this.row = row;
|
|
|
+ this.index = row * columnCount;
|
|
|
+ this.endIndex = index + columnCount;
|
|
|
+ }
|
|
|
+
|
|
|
+ public RowBuilder add(Object columnValue) {
|
|
|
+ if (index == endIndex) {
|
|
|
+ throw new CursorIndexOutOfBoundsException("No more columns left.");
|
|
|
+ }
|
|
|
+ data[index++] = columnValue;
|
|
|
+ return this;
|
|
|
+ }
|
|
|
+
|
|
|
+ public RowBuilder add(String columnName, Object value) {
|
|
|
+ for (int i = 0; i < columnNames.length; i++) {
|
|
|
+ if (columnName.equals(columnNames[i])) {
|
|
|
+ data[(row * columnCount) + i] = value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return this;
|
|
|
+ }
|
|
|
+
|
|
|
+ public final RowBuilder add(int columnIndex, Object value) {
|
|
|
+ data[(row * columnCount) + columnIndex] = value;
|
|
|
+ return this;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getCount() {
|
|
|
+ return rowCount;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String[] getColumnNames() {
|
|
|
+ return columnNames;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String getString(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ if (value == null) return null;
|
|
|
+ return value.toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public short getShort(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ if (value == null) return 0;
|
|
|
+ if (value instanceof Number) return ((Number) value).shortValue();
|
|
|
+ return Short.parseShort(value.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getInt(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ if (value == null) return 0;
|
|
|
+ if (value instanceof Number) return ((Number) value).intValue();
|
|
|
+ return Integer.parseInt(value.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public long getLong(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ if (value == null) return 0;
|
|
|
+ if (value instanceof Number) return ((Number) value).longValue();
|
|
|
+ return Long.parseLong(value.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public float getFloat(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ if (value == null) return 0.0f;
|
|
|
+ if (value instanceof Number) return ((Number) value).floatValue();
|
|
|
+ return Float.parseFloat(value.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public double getDouble(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ if (value == null) return 0.0d;
|
|
|
+ if (value instanceof Number) return ((Number) value).doubleValue();
|
|
|
+ return Double.parseDouble(value.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public byte[] getBlob(int column) {
|
|
|
+ Object value = get(column);
|
|
|
+ return (byte[]) value;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getType(int column) {
|
|
|
+ return getTypeOfObject(get(column));
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean isNull(int column) {
|
|
|
+ return get(column) == null;
|
|
|
+ }
|
|
|
+
|
|
|
+ public static int getTypeOfObject(Object obj) {
|
|
|
+ if (obj == null) {
|
|
|
+ return Cursor.FIELD_TYPE_NULL;
|
|
|
+ } else if (obj instanceof byte[]) {
|
|
|
+ return Cursor.FIELD_TYPE_BLOB;
|
|
|
+ } else if (obj instanceof Float || obj instanceof Double) {
|
|
|
+ return Cursor.FIELD_TYPE_FLOAT;
|
|
|
+ } else if (obj instanceof Long || obj instanceof Integer
|
|
|
+ || obj instanceof Short || obj instanceof Byte) {
|
|
|
+ return Cursor.FIELD_TYPE_INTEGER;
|
|
|
+ } else {
|
|
|
+ return Cursor.FIELD_TYPE_STRING;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
Milan Jurkulak