本文整理了Java中java.sql.ResultSet.getArray
方法的一些代码示例,展示了ResultSet.getArray
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ResultSet.getArray
方法的具体详情如下:
包路径:java.sql.ResultSet
类名称:ResultSet
方法名:getArray
[英]Gets the content of a column specified by column index in the current row of this ResultSet as a java.sql.Array.
[中]获取此结果集当前行中由列索引指定的列的内容。sql。大堆
代码示例来源:origin: org.postgresql/postgresql
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
byte[] schema = rs.getBytes("nspname");
byte[] procedureName = rs.getBytes("proname");
Array argNamesArray = rs.getArray("proargnames");
if (argNamesArray != null) {
argNames = (String[]) argNamesArray.getArray();
Array argModesArray = rs.getArray("proargmodes");
if (argModesArray != null) {
argModes = (String[]) argModesArray.getArray();
Array allArgTypesArray = rs.getArray("proallargtypes");
if (allArgTypesArray != null) {
allArgTypes = (Long[]) allArgTypesArray.getArray();
+ " AND NOT a.attisdropped AND a.attnum > 0 ORDER BY a.attnum ";
Statement columnstmt = connection.createStatement();
ResultSet columnrs = columnstmt.executeQuery(columnsql);
while (columnrs.next()) {
int columnTypeOid = (int) columnrs.getLong("atttypid");
byte[][] tuple = new byte[columns][];
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionDate() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"DATE\",3) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{new Date(1432102334184l), new Date(1432102334184l), new Date(1432102334184l)};
Array array = conn.createArrayOf("DATE", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionVarChar() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"varchar\",4) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{"foo", "foo", "foo", "foo"};
Array array = conn.createArrayOf("VARCHAR", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: postgresql/postgresql
ResultSet rs = connection.createStatement().executeQuery(sql);
while (rs.next())
Array argNamesArray = rs.getArray("proargnames");
if (argNamesArray != null)
argNames = (String[])argNamesArray.getArray();
Array argModesArray = rs.getArray("proargmodes");
if (argModesArray != null)
argModes = (String[])argModesArray.getArray();
Array allArgTypesArray = rs.getArray("proallargtypes");
if (allArgTypesArray != null) {
ResultSet columnrs = connection.createStatement().executeQuery(columnsql);
while (columnrs.next())
代码示例来源:origin: apache/phoenix
@Test
public void testArrayRemoveFunctionCharsWithNull() throws Exception {
ResultSet rs = conn.createStatement().executeQuery(
"SELECT ARRAY_REMOVE(chars,NULL) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
assertEquals(conn.createArrayOf("CHAR", new String[] { "a", "bbbb", "c", "ddd", "e", "c" }), rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayRemoveFunctionOneElement() throws Exception {
ResultSet rs = conn.createStatement().executeQuery(
"SELECT ARRAY_REMOVE(oneItem,'alone') FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
assertEquals(conn.createArrayOf("VARCHAR", new String[0]), rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionTime() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"time\",3) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{new Time(1432102334184l), new Time(1432102334184l), new Time(1432102334184l)};
Array array = conn.createArrayOf("TIME", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionTimestamp() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"timestamp\",3) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{new Timestamp(1432102334184l), new Timestamp(1432102334184l), new Timestamp(1432102334184l)};
Array array = conn.createArrayOf("TIMESTAMP", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionInteger() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"integer\",4) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{34, 34, 34, 34};
Array array = conn.createArrayOf("INTEGER", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayRemoveFunctionVarchar() throws Exception {
ResultSet rs = conn.createStatement().executeQuery(
"SELECT ARRAY_REMOVE(varchars,'23234') FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
assertEquals(conn.createArrayOf("VARCHAR", new String[] { "2345", "46345" }), rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayRemoveFunctionFirstElement() throws Exception {
ResultSet rs = conn.createStatement().executeQuery(
"SELECT ARRAY_REMOVE(varchars,'2345') FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
assertEquals(conn.createArrayOf("VARCHAR", new String[] { "46345", "23234" }), rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayRemoveFunctionMiddleElement() throws Exception {
ResultSet rs = conn.createStatement().executeQuery(
"SELECT ARRAY_REMOVE(varchars,'46345') FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
assertEquals(conn.createArrayOf("VARCHAR", new String[] { "2345", "23234" }), rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayRemoveFunctionVarcharFromCharArray() throws Exception {
ResultSet rs = conn.createStatement().executeQuery(
"SELECT ARRAY_REMOVE(chars,varchar1) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
assertEquals(conn.createArrayOf("CHAR", new String[] { "bbbb", "c", "ddd", "e", "c" }), rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionBigint() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"bigint\",4) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{34567l, 34567l, 34567l, 34567l};
Array array = conn.createArrayOf("BIGINT", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionVarchar() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"varchar\",5) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
String[] strings = new String[]{"foo", "foo", "foo", "foo", "foo"};
Array array = conn.createArrayOf("VARCHAR", strings);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionDouble() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"double\",4) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{23.45, 23.45, 23.45, 23.45};
Array array = conn.createArrayOf("DOUBLE", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionChar() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"char\",4) FROM " + tableName + " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{"foo", "foo", "foo", "foo"};
Array array = conn.createArrayOf("CHAR", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test(expected = IllegalArgumentException.class)
public void testArrayFillFunctionInvalidLength2() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"timestamp\",length1) FROM " + tableName
+ " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{new Timestamp(1432102334184l), new Timestamp(1432102334184l), new Timestamp(1432102334184l)};
Array array = conn.createArrayOf("TIMESTAMP", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test(expected = IllegalArgumentException.class)
public void testArrayFillFunctionInvalidLength1() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(\"timestamp\",length2) FROM " + tableName
+ " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{new Timestamp(1432102334184l), new Timestamp(1432102334184l), new Timestamp(1432102334184l)};
Array array = conn.createArrayOf("TIMESTAMP", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
代码示例来源:origin: apache/phoenix
@Test
public void testArrayFillFunctionWithNestedFunctions3() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
ResultSet rs;
rs = conn.createStatement().executeQuery(
"SELECT ARRAY_FILL(3.4, ARRAY_LENGTH(ARRAY[34, 45])) FROM " + tableName
+ " WHERE region_name = 'SF Bay Area'");
assertTrue(rs.next());
Object[] objects = new Object[]{BigDecimal.valueOf(3.4), BigDecimal.valueOf(3.4)};
Array array = conn.createArrayOf("DECIMAL", objects);
assertEquals(array, rs.getArray(1));
assertFalse(rs.next());
}
内容来源于网络,如有侵权,请联系作者删除!