Examples of PhoenixResultSet

com.salesforce.phoenix.jdbc.PhoenixResultSet
JDBC ResultSet implementation of Phoenix. Currently only the following data types are supported: - String - Date - Time - Timestamp - BigDecimal - Double - Float - Int - Short - Long - Binary - Array - 1D None of the update or delete methods are supported. The ResultSet only supports the following options: - ResultSet.FETCH_FORWARD - ResultSet.CONCUR_READ_ONLY - ResultSet.TYPE_FORWARD_ONLY - ResultSet.CLOSE_CURSORS_AT_COMMIT @author jtaylor @since 0.1
org.apache.phoenix.jdbc.PhoenixResultSet
JDBC ResultSet implementation of Phoenix. Currently only the following data types are supported: - String - Date - Time - Timestamp - BigDecimal - Double - Float - Int - Short - Long - Binary - Array - 1D None of the update or delete methods are supported. The ResultSet only supports the following options: - ResultSet.FETCH_FORWARD - ResultSet.CONCUR_READ_ONLY - ResultSet.TYPE_FORWARD_ONLY - ResultSet.CLOSE_CURSORS_AT_COMMIT @since 0.1

Examples of org.apache.phoenix.jdbc.PhoenixResultSet

                values[offset++] = tenantId;
            }
            if (isSharedViewIndex) {
                values[offset++] = MetaDataUtil.getViewIndexIdDataType().toBytes(table.getViewIndexId());
            }
            ResultSet rs = new PhoenixResultSet(iterator, projector, statement);
            int rowCount = 0;
            while (rs.next()) {
                for (int i = offset; i < values.length; i++) {
                    byte[] byteValue = rs.getBytes(i+1-offset);
                    // The ResultSet.getBytes() call will have inverted it - we need to invert it back.
                    // TODO: consider going under the hood and just getting the bytes
                    if (pkColumns.get(i).getSortOrder() == SortOrder.DESC) {
                        byte[] tempByteValue = Arrays.copyOf(byteValue, byteValue.length);
                        byteValue = SortOrder.invert(byteValue, 0, tempByteValue, 0, byteValue.length);

View Full Code Here

Examples of org.apache.phoenix.jdbc.PhoenixResultSet

                values[offset++] = tenantId;
            }
            if (isSharedViewIndex) {
                values[offset++] = MetaDataUtil.getViewIndexIdDataType().toBytes(table.getViewIndexId());
            }
            ResultSet rs = new PhoenixResultSet(iterator, projector, statement);
            int rowCount = 0;
            while (rs.next()) {
                for (int i = offset; i < values.length; i++) {
                    byte[] byteValue = rs.getBytes(i+1-offset);
                    // The ResultSet.getBytes() call will have inverted it - we need to invert it back.
                    // TODO: consider going under the hood and just getting the bytes
                    if (pkColumns.get(i).getSortOrder() == SortOrder.DESC) {
                        byte[] tempByteValue = Arrays.copyOf(byteValue, byteValue.length);
                        byteValue = SortOrder.invert(byteValue, 0, tempByteValue, 0, byteValue.length);

View Full Code Here

Examples of org.apache.phoenix.jdbc.PhoenixResultSet

            boolean isAutoCommit = connection.getAutoCommit();
            byte[][] values = new byte[columnIndexes.length][];
            int rowCount = 0;
            Map<ImmutableBytesPtr,Map<PColumn,byte[]>> mutation = Maps.newHashMapWithExpectedSize(batchSize);
            PTable table = tableRef.getTable();
            ResultSet rs = new PhoenixResultSet(iterator, projector, statement);
            ImmutableBytesWritable ptr = new ImmutableBytesWritable();
            while (rs.next()) {
                for (int i = 0; i < values.length; i++) {
                    PColumn column = table.getColumns().get(columnIndexes[i]);
                    byte[] bytes = rs.getBytes(i+1);
                    ptr.set(bytes == null ? ByteUtil.EMPTY_BYTE_ARRAY : bytes);
                    Object value = rs.getObject(i+1);
                    int rsPrecision = rs.getMetaData().getPrecision(i+1);
                    Integer precision = rsPrecision == 0 ? null : rsPrecision;
                    int rsScale = rs.getMetaData().getScale(i+1);
                    Integer scale = rsScale == 0 ? null : rsScale;
                    // We are guaranteed that the two column will have compatible types,
                    // as we checked that before.
                    if (!column.getDataType().isSizeCompatible(ptr, value, column.getDataType(),
                            precision, scale,

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.