private void handleResultSet(List<Map<String,Object>> list,ResultSet resultSet) {
try {
if (resultSet != null && resultSet.last()) {
resultSet.beforeFirst();
ResultSetMetaData rsmd = resultSet.getMetaData();
while (resultSet.next()) {
Map<String,Object> map = Maps.newHashMap();
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
map.put(rsmd.getColumnName(i),resultSet.getString(i));
}
list.add(map);
}
resultSet.beforeFirst();
resultSet.close();
}
} catch (sqlException e) {
e.printstacktrace();
}
}
项目：Mona-Secure-Multi-Owner-Data-Sharing-for-Dynamic-Group-in-the-Cloud
文件：RegistrationDAO.java
public Object[] viewCloudMetaData() {
return jdbcTemplate.query(
"select * from CLOUDFILEDATA order by FILEDATAID",new ResultSetExtractor<Object[]>() {
public Object[] extractData(ResultSet rs)
throws sqlException,DataAccessException {
ResultSetMetaData resultSetMetaData = rs.getMetaData();
String tableMetadata[] = new String[] {
resultSetMetaData.getColumnName(1),resultSetMetaData.getColumnName(2),resultSetMetaData.getColumnName(3),resultSetMetaData.getColumnName(4),resultSetMetaData.getColumnName(5),resultSetMetaData.getColumnName(6),resultSetMetaData.getColumnName(9),resultSetMetaData.getColumnName(10),resultSetMetaData.getColumnName(11),};
return tableMetadata;
}
});
}
项目：AnyMall
文件：PooledConnection.java
private List<Object[]> readResultSet(ResultSet rs) throws sqlException {
if (rs == null) {
return null;
}
List<Object[]> array = new ArrayList<Object[]>();
ResultSetMetaData Metadata = rs.getMetaData();
int nColumn = Metadata.getColumnCount();
//��ӱ�ͷ
Object[] columnNames = new Object[nColumn];
for (int i = 1; i <= nColumn; i++) {
columnNames[i - 1] = Metadata.getColumnName(i);
}
array.add(columnNames);
//��ȡ����
while (rs.next()) {
Object[] row = new Object[nColumn];
for (int i = 0; i < nColumn; i++) {
row[i] = rs.getobject(i + 1);
}
array.add(row);
}
return array;
}
/**
* Checks if parametrised query execution is working correctly.
*/
@Test
public void shouldExecuteParametrisedQuery() {
sqlScriptExecutor executor = sqlScriptExecutorProvider.get(new LoggingsqlScriptVisitor());
SelectStatement testSelect = select(field("alfaDate1"),field("alfaDate2"),literal(123))
.from(tableRef("DateTable")).where(eq(field("alfaDate1"),parameter("firstDateParam").type(DataType.BIG_INTEGER)));;
Iterable<sqlParameter> parameterMetadata = ImmutableList.of(parameter(column("firstDateParam",DataType.STRING)));
RecordBuilder parameterData = DataSetUtils.record().setString("firstDateParam","20040609");
ResultSetProcessor<List<List<String>>> resultSetProcessor = new ResultSetProcessor<List<List<String>>>() {
/**
* Takes all rows and puts into two-dimension String array.
*/
@Override
public List<List<String>> process(ResultSet resultSet) throws sqlException {
Builder<List<String>> builder = ImmutableList.<List<String>>builder();
ResultSetMetaData MetaData = resultSet.getMetaData();
int columnCount = MetaData.getColumnCount();
while (resultSet.next()) {
List<String> rowBuilder = new LinkedList<>();
for (int columnNumber = 1; columnNumber < columnCount + 1; columnNumber++) {
String stringifiezedCell = resultSet.getString(columnNumber);
rowBuilder.add(stringifiezedCell);
}
builder.add(rowBuilder);
}
return builder.build();
}
};
List<List<String>> result = executor.executeQuery(testSelect,parameterMetadata,parameterData,connection,resultSetProcessor);
assertEquals(ImmutableList.of(ImmutableList.of("20040609","20040813","123"),ImmutableList.of("20040609","20040609","20040610","123")),result);
}
项目：adept
文件：MapListHandler.java
/**
* 将'ResultSet'结果集转换为'Map的List集合'的方法.
* @param rs ResultSet实例
* @return Map的List集合
*/
@Override
public List<Map<String,Object>> transform(ResultSet rs) {
if (rs == null) {
return null;
}
// 遍历Resultset和元数据，将每一行各列的数据存到Map中，然后将各行数据add到List集合中
List<Map<String,Object>> maps = new ArrayList<Map<String,Object>>();
try {
ResultSetMetaData rsmd = rs.getMetaData();
while (rs.next()) {
Map<String,Object> map = new HashMap<String,Object>();
for (int i = 0,cols = rsmd.getColumnCount(); i < cols; i++) {
map.put(JdbcHelper.getColumn(rsmd,i + 1),rs.getobject(i + 1));
}
maps.add(map);
}
} catch (Exception e) {
throw new ResultsTransformException("将'ResultSet'结果集转换为'map的List集合'出错!",e);
}
return maps;
}
/** Creates new form SelectParameters */
public SelectParametersjdialog(ResultSetMetaData rs) throws sqlException {
initComponents();
this.setModal(true);
int cols = rs.getColumnCount();
for (int i = 0; i < cols; i++) {
jComboBox_lat.insertItemAt(rs.getColumnName(i + 1),i);
if (rs.getColumnName(i + 1).equalsIgnoreCase("lat") || rs.getColumnName(i + 1).equalsIgnoreCase("latitude")) {
jComboBox_lat.setSelectedItem(rs.getColumnName(i + 1));
}
jComboBox_lon.insertItemAt(rs.getColumnName(i + 1),i);
if (rs.getColumnName(i + 1).equalsIgnoreCase("lon") || rs.getColumnName(i + 1).equalsIgnoreCase("longitude")) {
jComboBox_lon.setSelectedItem(rs.getColumnName(i + 1));
}
jComboBox_time.insertItemAt(rs.getColumnName(i + 1),i);
if (rs.getColumnName(i + 1).equalsIgnoreCase("time") || rs.getColumnName(i + 1).equalsIgnoreCase("date")) {
jComboBox_time.setSelectedItem(rs.getColumnName(i + 1));
}
}
jComboBox_time.insertItemAt("",cols);
}
/**
* Tests BUG13601 (which doesn't seem to be present in 3.1.11,but we'll
* leave it in here for regression's-sake).
*
* @throws Exception
* if the test fails.
*/
public void testBug13601() throws Exception {
if (versionMeetsMinimum(5,0)) {
createTable("testBug13601","(field1 BIGINT NOT NULL,field2 BIT default 0 NOT NULL) ENGINE=MyISAM");
this.rs = this.stmt.executeQuery("SELECT field1,field2 FROM testBug13601 WHERE 1=-1");
ResultSetMetaData rsmd = this.rs.getMetaData();
assertEquals(Types.BIT,rsmd.getColumnType(2));
assertEquals(Boolean.class.getName(),rsmd.getColumnClassName(2));
this.rs = this.conn.prepareStatement("SELECT field1,field2 FROM testBug13601 WHERE 1=-1").executeQuery();
rsmd = this.rs.getMetaData();
assertEquals(Types.BIT,rsmd.getColumnClassName(2));
}
}
项目：jforgame
文件：BeanProcessor.java
public <T> List<T> toBeanList(ResultSet rs,Class<T> type)
throws sqlException
{
List<T> results = new ArrayList();
if (!rs.next()) {
return results;
}
PropertyDescriptor[] props = propertyDescriptors(type);
ResultSetMetaData rsmd = rs.getMetaData();
int[] columnToProperty = mapColumnsToProperties(rsmd,props);
do
{
results.add(createBean(rs,type,props,columnToProperty));
} while (rs.next());
return results;
}
/**
* Tests for types being returned correctly
*
* @throws Exception
* if an error occurs.
*/
public void testTypes() throws Exception {
try {
this.stmt.execute("DROP TABLE IF EXISTS typesRegresstest");
this.stmt.execute("CREATE TABLE typesRegresstest (varcharField VARCHAR(32),charField CHAR(2),enumField ENUM('1','2'),"
+ "setField SET('1','2','3'),tinyblobField TINYBLOB,mediumBlobField MEDIUMBLOB,longblobField LONGBLOB,blobField BLOB)");
this.rs = this.stmt.executeQuery("SELECT * from typesRegresstest");
ResultSetMetaData rsmd = this.rs.getMetaData();
int numCols = rsmd.getColumnCount();
for (int i = 0; i < numCols; i++) {
String columnName = rsmd.getColumnName(i + 1);
String columnTypeName = rsmd.getColumnTypeName(i + 1);
System.out.println(columnName + " -> " + columnTypeName);
}
} finally {
this.stmt.execute("DROP TABLE IF EXISTS typesRegresstest");
}
}
public static void dump(ResultSet rs) throws sqlException {
// the order of the rows in a cursor
// are implementation dependent unless you use the sql ORDER statement
ResultSetMetaData Meta = rs.getMetaData();
int colmax = Meta.getColumnCount();
int i;
Object o = null;
// the result set is a cursor into the data. You can only
// point to one row at a time
// assume we are pointing to BEFORE the first row
// rs.next() points to next row and returns true
// or false if there is no next row,which breaks the loop
for (; rs.next(); ) {
for (i = 0; i < colmax; ++i) {
o = rs.getobject(i + 1); // Is sql the first column is indexed
// with 1 not 0
System.out.print(o.toString() + " ");
}
System.out.println(" ");
}
}
/**
* Tests fix for BUG#2852,where RSMD is not returning correct (or matching)
* types for tinyint and SMALLINT.
*
* @throws Exception
* if the test fails.
*/
public void testBug2852() throws Exception {
try {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug2852");
this.stmt.executeUpdate("CREATE TABLE testBug2852 (field1 tinyint,field2 SMALLINT)");
this.stmt.executeUpdate("INSERT INTO testBug2852 VALUES (1,1)");
this.rs = this.stmt.executeQuery("SELECT * from testBug2852");
assertTrue(this.rs.next());
ResultSetMetaData rsmd = this.rs.getMetaData();
assertTrue(rsmd.getColumnClassName(1).equals(this.rs.getobject(1).getClass().getName()));
assertTrue("java.lang.Integer".equals(rsmd.getColumnClassName(1)));
assertTrue(rsmd.getColumnClassName(2).equals(this.rs.getobject(2).getClass().getName()));
assertTrue("java.lang.Integer".equals(rsmd.getColumnClassName(2)));
} finally {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug2852");
}
}
项目：OpenDiabetes
文件：Testdb.java
public static void dump(ResultSet rs) throws sqlException {
// the order of the rows in a cursor
// are implementation dependent unless you use the sql ORDER statement
ResultSetMetaData Meta = rs.getMetaData();
int colmax = Meta.getColumnCount();
int i;
Object o = null;
// the result set is a cursor into the data. You can only
// point to one row at a time
// assume we are pointing to BEFORE the first row
// rs.next() points to next row and returns true
// or false if there is no next row,which breaks the loop
for (; rs.next(); ) {
for (i = 0; i < colmax; ++i) {
o = rs.getobject(i + 1); // Is sql the first column is indexed
// with 1 not 0
System.out.print(o.toString() + " ");
}
System.out.println(" ");
}
}
/**
* Tests fix for BUG#2855,where RSMD is not returning correct (or matching)
* types for FLOAT.
*
* @throws Exception
* if the test fails.
*/
public void testBug2855() throws Exception {
try {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug2855");
this.stmt.executeUpdate("CREATE TABLE testBug2855 (field1 FLOAT)");
this.stmt.executeUpdate("INSERT INTO testBug2855 VALUES (1)");
this.rs = this.stmt.executeQuery("SELECT * from testBug2855");
assertTrue(this.rs.next());
ResultSetMetaData rsmd = this.rs.getMetaData();
assertTrue(rsmd.getColumnClassName(1).equals(this.rs.getobject(1).getClass().getName()));
assertTrue("java.lang.Float".equals(rsmd.getColumnClassName(1)));
} finally {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug2855");
}
}
项目：spring-boot-data-source-decorator
文件：SampleController.java
@RequestMapping("/commit")
public List<Map<String,String>> select() {
List<Map<String,String>> results = new ArrayList<>();
try (Connection connection = dataSource.getConnection();
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM @R_60_4045@ION_SCHEMA.COLUMNS")) {
ResultSetMetaData MetaData = resultSet.getMetaData();
while (resultSet.next()) {
Map<String,String> result = new HashMap<>();
for (int i = 0; i < MetaData.getColumnCount(); i++) {
String columnName = MetaData.getColumnName(i + 1);
result.put(columnName,resultSet.getString(columnName));
}
results.add(result);
}
connection.commit();
}
catch (Exception e) {
throw new IllegalStateException(e);
}
return results;
}
项目：slardar
文件：BeanWrapper.java
/**
* bean生成模块抽取
* @param rs
* @param Meta
* @param type
* @return
*/
private T createBean(ResultSet rs,ResultSetMetaData Meta,Class<T> type) {
Object object = ReflectUtils.newInstance(type);
try {
int count = Meta.getColumnCount();
for (int i = 0; i < count; i++) {
Object value = rs.getobject(i + 1);
String propertyName = fieldBinder.getProperty(type,Meta.getColumnName(i + 1));
if (StringUtils.isEmpty(propertyName)){
ReflectUtils.setFieldValue(object,Meta.getColumnName(i + 1),value);
}else{
ReflectUtils.setFieldValue(object,propertyName,value);
}
}
return (T) object;
} catch (sqlException e) {
e.printstacktrace();
return null;
}
}
/**
* Tests fix for BUG#2855,where RSMD is not returning correct (or matching)
* types for FLOAT.
*
* @throws Exception
* if the test fails.
*/
public void testBug2855() throws Exception {
try {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug2855");
this.stmt.executeUpdate("CREATE TABLE testBug2855 (field1 FLOAT)");
this.stmt.executeUpdate("INSERT INTO testBug2855 VALUES (1)");
this.rs = this.stmt.executeQuery("SELECT * from testBug2855");
assertTrue(this.rs.next());
ResultSetMetaData rsmd = this.rs.getMetaData();
assertTrue(rsmd.getColumnClassName(1).equals(this.rs.getobject(1).getClass().getName()));
assertTrue("java.lang.Float".equals(rsmd.getColumnClassName(1)));
} finally {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug2855");
}
}
/**
* ensures two tables (or views,that is) have the same content
*/
private void ensureEqualContent(String tableNameLHS,String tableNameRHS) throws sqlException {
ResultSet lhs = m_statement.executeQuery("SELECT * FROM \""
+ tableNameLHS + "\"");
ResultSet rhs = m_statement.executeQuery("SELECT * FROM \""
+ tableNameRHS + "\"");
ResultSetMetaData Meta = lhs.getMetaData();
while (lhs.next() && rhs.next()) {
for (int col = 1; col <= Meta.getColumnCount(); ++col) {
assertEquals("table content does not match: cp. "
+ tableNameLHS + "-" + tableNameRHS + ",row "
+ lhs.getRow() + ",col "
+ col,lhs.getobject(col),rhs.getobject(col));
}
}
// lhs should be after last,rhs still on last
assertTrue("row count does not match: " + tableNameLHS + "-"
+ tableNameRHS,lhs.isAfterLast() && rhs.isLast());
}
/**
* Tests fix for BUG#6399,ResultSetMetaData.getdisplaySize() is wrong for
* multi-byte charsets.
*
* @throws Exception
* if the test fails
*/
public void testBug6399() throws Exception {
if (versionMeetsMinimum(4,1)) {
try {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug6399");
this.stmt.executeUpdate(
"CREATE TABLE testBug6399 (field1 CHAR(3) CHaraCTER SET UTF8,field2 CHAR(3) CHaraCTER SET latin1,field3 CHAR(3) CHaraCTER SET SJIS)");
this.stmt.executeUpdate("INSERT INTO testBug6399 VALUES ('a','a','a')");
this.rs = this.stmt.executeQuery("SELECT field1,field2,field3 FROM testBug6399");
ResultSetMetaData rsmd = this.rs.getMetaData();
assertEquals(3,rsmd.getColumndisplaySize(1));
assertEquals(3,rsmd.getColumndisplaySize(2));
assertEquals(3,rsmd.getColumndisplaySize(3));
} finally {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug6399");
}
}
}
/**
* Tests BUG13601 (which doesn't seem to be present in 3.1.11,rsmd.getColumnClassName(2));
}
}
/**
* Tests fix for BUG#6399,rsmd.getColumndisplaySize(3));
} finally {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug6399");
}
}
}
/** (Worked before.) */
@Test
public void testInfoSchemaTablesZeroRowsByWhereFalseWorks() throws Exception {
Statement stmt = connection.createStatement();
ResultSet results =
stmt.executeQuery(
"SELECT * FROM @R_60_4045@ION_SCHEMA.`TABLES` WHERE FALSE" );
// Result set should still have columns even though there are no rows:
ResultSetMetaData Metadata = results.getMetaData();
assertthat( "ResultSetMetaData.getColumnCount() should have been > 0",Metadata.getColumnCount(),not( equalTo( 0 ) ) );
assertthat( "Unexpected non-empty results. Test rot?",false,equalTo( results.next() ) );
}
项目：limitjson
文件：FlipTableConverters.java
/**
* Create a table from a {@link ResultSet}.
*/
public static String fromresultSet(ResultSet resultSet) throws sqlException {
if (resultSet == null) throw new NullPointerException("resultSet == null");
if (!resultSet.isBeforeFirst()) throw new IllegalStateException("Result set not at first.");
List<String> headers = new ArrayList<>();
ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
int columnCount = resultSetMetaData.getColumnCount();
for (int column = 0; column < columnCount; column++) {
headers.add(resultSetMetaData.getColumnName(column + 1));
}
List<String[]> data = new ArrayList<>();
while (resultSet.next()) {
String[] rowData = new String[columnCount];
for (int column = 0; column < columnCount; column++) {
rowData[column] = resultSet.getString(column + 1);
}
data.add(rowData);
}
String[] headerArray = headers.toArray(new String[headers.size()]);
String[][] dataArray = data.toArray(new String[data.size()][]);
return FlipTable.of(headerArray,dataArray);
}
项目：lams
文件：SingleColumnRowMapper.java
/**
* Extract a value for the single column in the current row.
* <p>Validates that there is only one column selected,* then delegates to {@code getColumnValue()} and also
* {@code convertValuetorequiredType},if necessary.
* @see java.sql.ResultSetMetaData#getColumnCount()
* @see #getColumnValue(java.sql.ResultSet,int,Class)
* @see #convertValuetorequiredType(Object,Class)
*/
@Override
@SuppressWarnings("unchecked")
public T mapRow(ResultSet rs,int rowNum) throws sqlException {
// Validate column count.
ResultSetMetaData rsmd = rs.getMetaData();
int nrOfColumns = rsmd.getColumnCount();
if (nrOfColumns != 1) {
throw new IncorrectResultSetColumnCountException(1,nrOfColumns);
}
// Extract column value from JDBC ResultSet.
Object result = getColumnValue(rs,1,this.requiredType);
if (result != null && this.requiredType != null && !this.requiredType.isinstance(result)) {
// Extracted value does not match already: try to convert it.
try {
return (T) convertValuetorequiredType(result,this.requiredType);
}
catch (IllegalArgumentException ex) {
throw new TypeMismatchDataAccessException(
"Type mismatch affecting row number " + rowNum + " and column type '" +
rsmd.getColumnTypeName(1) + "': " + ex.getMessage());
}
}
return (T) result;
}
/**
* Tests fix for BUG#27867 - Schema objects with identifiers other than the
* connection character aren't retrieved correctly in ResultSetMetadata.
*
* @throws Exception
* if the test fails.
*/
public void testBug27867() throws Exception {
if (!versionMeetsMinimum(4,1)) {
return;
}
String gbkColumnName = "\u00e4\u00b8\u00ad\u00e6\u2013\u2021\u00e6\u00b5\u2039\u00e8\u00af\u2022";
createTable("ColumnNameEncoding","(`" + gbkColumnName + "` varchar(1) default NULL,`ASCIIColumn` varchar(1) default NULL" + ")ENGINE=MyISAM DEFAULT CHARSET=utf8");
this.rs = this.stmt.executeQuery("SELECT * FROM ColumnNameEncoding");
java.sql.ResultSetMetaData tblMD = this.rs.getMetaData();
assertEquals(gbkColumnName,tblMD.getColumnName(1));
assertEquals("ASCIIColumn",tblMD.getColumnName(2));
}
项目：happylifeplat-transaction
文件：JdbcTransactionRecoverRepository.java
private List<Map<String,Object>> executeQuery(String sql,Object... params) {
List<Map<String,Object>> list = null;
try {
try(Connection connection = dataSource.getConnection();
PreparedStatement ps= connection.prepareStatement(sql)){
if (params != null) {
for (int i = 0; i < params.length; i++) {
ps.setobject((i + 1),params[i]);
}
}
ResultSet rs = ps.executeQuery();
ResultSetMetaData md = rs.getMetaData();
int columnCount = md.getColumnCount();
list = new ArrayList<>();
while (rs.next()) {
Map<String,Object> rowData = Maps.newHashMap();
for (int i = 1; i <= columnCount; i++) {
rowData.put(md.getColumnName(i),rs.getobject(i));
}
list.add(rowData);
}
}
} catch (sqlException e) {
e.printstacktrace();
LOGGER.error("executeQuery->" + e.getMessage());
}
return list;
}
项目：openjdk-jdk10
文件：CommonCachedRowSetTests.java
private void compareMetaData(ResultSetMetaData rsmd,ResultSetMetaData rsmd1) throws sqlException {
assertEquals(rsmd1.getColumnCount(),rsmd.getColumnCount());
int cols = rsmd.getColumnCount();
for (int i = 1; i <= cols; i++) {
assertTrue(rsmd1.getCatalogName(i).equals(rsmd.getCatalogName(i)));
assertTrue(rsmd1.getColumnClassName(i).equals(rsmd.getColumnClassName(i)));
assertTrue(rsmd1.getColumndisplaySize(i) == rsmd.getColumndisplaySize(i));
assertTrue(rsmd1.getColumnLabel(i).equals(rsmd.getColumnLabel(i)));
assertTrue(rsmd1.getColumnName(i).equals(rsmd.getColumnName(i)));
assertTrue(rsmd1.getColumnType(i) == rsmd.getColumnType(i));
assertTrue(rsmd1.getPrecision(i) == rsmd.getPrecision(i));
assertTrue(rsmd1.getScale(i) == rsmd.getScale(i));
assertTrue(rsmd1.getSchemaName(i).equals(rsmd.getSchemaName(i)));
assertTrue(rsmd1.getTableName(i).equals(rsmd.getTableName(i)));
assertTrue(rsmd1.isAutoIncrement(i) == rsmd.isAutoIncrement(i));
assertTrue(rsmd1.isCaseSensitive(i) == rsmd.isCaseSensitive(i));
assertTrue(rsmd1.isCurrency(i) == rsmd.isCurrency(i));
assertTrue(rsmd1.isDefinitelyWritable(i) == rsmd.isDefinitelyWritable(i));
assertTrue(rsmd1.isNullable(i) == rsmd.isNullable(i));
assertTrue(rsmd1.isReadOnly(i) == rsmd.isReadOnly(i));
assertTrue(rsmd1.isSearchable(i) == rsmd.isSearchable(i));
assertTrue(rsmd1.isSigned(i) == rsmd.isSigned(i));
assertTrue(rsmd1.isWritable(i) == rsmd.isWritable(i));
}
}
/**
* Tests fix for BUG#4880 - RSMD.getPrecision() returns '0' for non-numeric
* types.
*
* Why-oh-why is this not in the spec,nor the api-docs,but in some
* 'optional' book,_and_ it is a variance from both ODBC and the ANSI sql
* standard :p
*
* (from the CTS testsuite)....
*
* The getPrecision(int colindex) method returns an integer value
* representing the number of decimal digits for number types,maximum length
* in characters for character types,maximum length in bytes for JDBC binary
* datatypes.
*
* (See Section 27.3 of JDBC 2.0 API Reference & Tutorial 2nd edition)
*
* @throws Exception
* if the test fails.
*/
public void testBug4880() throws Exception {
try {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug4880");
this.stmt.executeUpdate("CREATE TABLE testBug4880 (field1 VARCHAR(80),field2 TINYBLOB,field3 BLOB,field4 MEDIUMBLOB,field5 LONGBLOB)");
this.rs = this.stmt.executeQuery("SELECT field1,field3,field4,field5 FROM testBug4880");
ResultSetMetaData rsmd = this.rs.getMetaData();
assertEquals(80,rsmd.getPrecision(1));
assertEquals(Types.VARCHAR,rsmd.getColumnType(1));
assertEquals(80,rsmd.getColumndisplaySize(1));
assertEquals(255,rsmd.getPrecision(2));
assertEquals(Types.VARBINARY,rsmd.getColumnType(2));
assertTrue("TINYBLOB".equalsIgnoreCase(rsmd.getColumnTypeName(2)));
assertEquals(255,rsmd.getColumndisplaySize(2));
assertEquals(65535,rsmd.getPrecision(3));
assertEquals(Types.LONGVARBINARY,rsmd.getColumnType(3));
assertTrue("BLOB".equalsIgnoreCase(rsmd.getColumnTypeName(3)));
assertEquals(65535,rsmd.getColumndisplaySize(3));
assertEquals(16777215,rsmd.getPrecision(4));
assertEquals(Types.LONGVARBINARY,rsmd.getColumnType(4));
assertTrue("MEDIUMBLOB".equalsIgnoreCase(rsmd.getColumnTypeName(4)));
assertEquals(16777215,rsmd.getColumndisplaySize(4));
if (versionMeetsMinimum(4,1)) {
// Server doesn't send us enough @R_60_4045@ion to detect LONGBLOB
// type
assertEquals(Integer.MAX_VALUE,rsmd.getPrecision(5));
assertEquals(Types.LONGVARBINARY,rsmd.getColumnType(5));
assertTrue("LONGBLOB".equalsIgnoreCase(rsmd.getColumnTypeName(5)));
assertEquals(Integer.MAX_VALUE,rsmd.getColumndisplaySize(5));
}
} finally {
this.stmt.executeUpdate("DROP TABLE IF EXISTS testBug4880");
}
}
项目：LivroJavaComoProgramar10Edicao
文件：JdbcRowSetTest.java
public static void main(String args[])
{
// connect to database books and query database
try (JdbcRowSet rowSet =
RowSetProvider.newFactory().createJdbcRowSet())
{
// specify JdbcRowSet properties
rowSet.setUrl(DATABASE_URL);
rowSet.setUsername(USERNAME);
rowSet.setPassword(PASSWORD);
rowSet.setCommand("SELECT * FROM authors"); // set query
rowSet.execute(); // execute query
// process query results
ResultSetMetaData MetaData = rowSet.getMetaData();
int numberOfColumns = MetaData.getColumnCount();
System.out.println("Authors Table of Books Database:\n");
// display rowset header
for (int i = 1; i <= numberOfColumns; i++)
System.out.printf("%-8s\t",MetaData.getColumnName(i));
System.out.println();
// display each row
while (rowSet.next())
{
for (int i = 1; i <= numberOfColumns; i++)
System.out.printf("%-8s\t",rowSet.getobject(i));
System.out.println();
}
}
catch (sqlException sqlException)
{
sqlException.printstacktrace();
System.exit(1);
}
}
/**
* Tests detection of read-only fields when the server is 4.1.0 or newer.
*
* @throws Exception
* if the test fails.
*/
public void testRSMdisReadOnly() throws Exception {
try {
this.rs = this.stmt.executeQuery("SELECT 1");
ResultSetMetaData rsmd = this.rs.getMetaData();
if (versionMeetsMinimum(4,1)) {
assertTrue(rsmd.isReadOnly(1));
try {
createTable("testRSMdisReadOnly","(field1 INT)");
this.stmt.executeUpdate("INSERT INTO testRSMdisReadOnly VALUES (1)");
this.rs = this.stmt.executeQuery("SELECT 1,field1 + 1,field1 FROM testRSMdisReadOnly");
rsmd = this.rs.getMetaData();
assertTrue(rsmd.isReadOnly(1));
assertTrue(rsmd.isReadOnly(2));
assertTrue(!rsmd.isReadOnly(3));
} finally {
}
} else {
assertTrue(rsmd.isReadOnly(1) == false);
}
} finally {
if (this.rs != null) {
this.rs.close();
}
}
}
项目：the-vigilantes
文件：StatementsTest.java
/**
* Test for CallableStatement.executeLargeUpdate().
* Validate update count returned and generated keys.
*/
public void testCallStmtExecuteLargeUpdate() throws Exception {
createTable("testExecuteLargeUpdate","(id BIGINT AUTO_INCREMENT PRIMARY KEY,n INT)");
createProcedure("testExecuteLargeUpdateProc","(IN n1 INT,IN n2 INT,IN n3 INT,IN n4 INT,IN n5 INT) BEGIN "
+ "INSERT INTO testExecuteLargeUpdate (n) VALUES (n1),(n2),(n3),(n4),(n5); END");
CallableStatement testCstmt = this.conn.prepareCall("{CALL testExecuteLargeUpdateProc(?,?,?)}");
testCstmt.setInt(1,1);
testCstmt.setInt(2,2);
testCstmt.setInt(3,3);
testCstmt.setInt(4,4);
testCstmt.setInt(5,5);
long count = testCstmt.executeLargeUpdate();
assertEquals(5,count);
assertEquals(5,testCstmt.getLargeUpdateCount());
this.rs = testCstmt.getGeneratedKeys();
// Although not requested,CallableStatements makes gerenated keys always available.
ResultSetMetaData rsmd = this.rs.getMetaData();
assertEquals(1,rsmd.getColumnCount());
assertEquals(JDBCType.BIGINT.getvendorTypeNumber().intValue(),rsmd.getColumnType(1));
assertEquals(20,rsmd.getColumndisplaySize(1));
// We can't check the generated keys as they are not returned correctly in this case (last_insert_id is missing from OK_PACKET when executing inserts
// within a stored procedure - Bug#21792359).
// long generatedKey = 0;
// while (this.rs.next()) {
// assertEquals(++generatedKey,this.rs.getLong(1));
// }
// assertEquals(5,generatedKey);
this.rs.close();
}
public boolean checkExist(String table) {
try {
// String sql = "SELECT COUNT(*) AS c FROM sqlite_master WHERE type ='table' AND name ='" + table + "' ";
String sql = "SELECT COUNT(*) FROM sqlite_master WHERE type='table' AND name='" + table + "';";
Statement statement = mConnection.createStatement();
ResultSet rs = statement.executeQuery(sql);
int count = 0;
if (rs != null && rs.next()) {
ResultSetMetaData rsmd = rs.getMetaData();
int columnCount = rsmd.getColumnCount();
if (columnCount > 0) {
count = rs.getInt(1);
}
}
statement.close();
rs.close();
return count > 0;
} catch (Exception e) {
e.printstacktrace();
}
return false;
}
项目：calcite-avatica
文件：RemoteDriverMockTest.java
@Test public void testTables() throws Exception {
final Connection connection = getMockConnection();
final ResultSet resultSet =
connection.getMetaData().getTables(null,null,new String[0]);
assertFalse(resultSet.next());
final ResultSetMetaData MetaData = resultSet.getMetaData();
assertTrue(MetaData.getColumnCount() >= 3);
assertEquals("TABLE_CAT",MetaData.getColumnName(1));
assertEquals("TABLE_SCHEM",MetaData.getColumnName(2));
assertEquals("TABLE_NAME",MetaData.getColumnName(3));
resultSet.close();
connection.close();
}
项目：mycat-src-1.6.1-RELEASE
文件：MongoResultSet.java
@Override
public ResultSetMetaData getMetaData() throws sqlException {
return new MongoResultSetMetaData(select,fieldtype,this._schema,this._table);
/*
if(_cur !=null){
return new MongoResultSetMetaData(_cur.keySet(),this._schema);
}
else{
return new MongoResultSetMetaData(select,this._schema);
}
*/
}
项目：dremio-oss
文件：DremioJdbc41Factory.java
@Override
public DremioResultSetImpl newResultSet(AvaticaStatement statement,QueryState state,Meta.Signature signature,TimeZone timeZone,Meta.Frame firstFrame) {
final ResultSetMetaData MetaData =
newResultSetMetaData(statement,signature);
return new DremioResultSetImpl(statement,state,signature,MetaData,timeZone,firstFrame);
}
项目：code-sentinel
文件：JDBCPersistentBB.java
/** returns true if the table for pi was created by Jason */
protected boolean isCreatedByJason(PredicateIndicator pi) throws sqlException {
ResultSetMetaData Meta = belsDB.get(pi);
if (Meta != null) {
int cols = Meta.getColumnCount();
return cols >= extraCols &&
Meta.getColumnName((cols - extraCols) + 1).equalsIgnoreCase(COL_NEG) &&
Meta.getColumnName((cols - extraCols) + 2).equalsIgnoreCase(COL_ANNOT);
}
return false;
}
public void testBug44508() throws Exception {
DatabaseMetaData dbmd = this.conn.getMetaData();
this.rs = dbmd.getSuperTypes("","","");
ResultSetMetaData rsmd = this.rs.getMetaData();
assertEquals("TYPE_CAT",rsmd.getColumnName(1)); // Gives TABLE_CAT
assertEquals("TYPE_SCHEM",rsmd.getColumnName(2)); // Gives TABLE_SCHEM
}
String fixupColumnDefRead(String aTableName,String columnType,ResultSet columnDesc,int columnIndex) throws sqlException {
String SeqName = new String("_" + columnDesc.getString(4) + "_seq");
int spaceleft = 31 - SeqName.length();
if (aTableName.length() > spaceleft) {
SeqName = aTableName.substring(0,spaceleft) + SeqName;
} else {
SeqName = aTableName + SeqName;
}
String CompareString = "nextval(\'\"" + SeqName + "\"\'";
if (columnType.indexOf(CompareString) >= 0) {
// We just found a increment
columnType = "SERIAL";
}
for (int Idx = 0; Idx < Funcs.length; Idx++) {
String ORACLE_func = Funcs[Idx][ORACLE];
int iStartPos = columnType.indexOf(ORACLE_func);
if (iStartPos >= 0) {
String NewColumnType = columnType.substring(0,iStartPos);
NewColumnType += Funcs[Idx][HsqlDB];
NewColumnType += columnType.substring(iStartPos
+ ORACLE_func.length());
columnType = NewColumnType;
}
}
return (columnType);
}
/**
* 数据库查询操作，返回单条记录
* @param sql语句
* @param 传入的占位符
* @return 返回Map集合类型，包含查询的结果
* @throws sqlException
*/
public Map<String,Object> returnSimpleResult(String sql,List<Object>params)
{
Map<String,Object>();
int index = 1;//从1开始设置占位符
try {
pStatement = connection.prepareStatement(sql);
if(params != null && !params.isEmpty()) /*判断参数是否为空*/
{
for(int i = 0;i<params.size();i++) /*循环填充占位符*/
{
pStatement.setobject(index++,params.get(i));
}
}
// System.out.println(pStatement.toString());
resultset = pStatement.executeQuery(sql);
/* 将查询结果封装到map集合*/
ResultSetMetaData MetaDate = resultset.getMetaData();//获取resultSet列的信息
int columnLength = MetaDate.getColumnCount();//获得列的长度
while(resultset.next())
{
for(int i = 0;i<columnLength;i++)
{
String MetaDateKey = MetaDate.getColumnName(i+1);//获得列名
Object resultsetValue = resultset.getobject(MetaDateKey);//通过列名获得值
if(resultsetValue == null)
{
resultsetValue = "";//转成String类型
}
map.put(MetaDateKey,resultsetValue);//添加到map集合（以上代码是为了将从数据库返回的值转换成map的key和value）
}
}
} catch (sqlException e) {
e.printstacktrace();
}
return map;
}
项目：code-sentinel
文件：JDBCPersistentBB.java
/** returns the where clausule for a select for literal l */
protected String getWhere(Literal l) throws sqlException {
ResultSetMetaData Meta = belsDB.get(l.getPredicateIndicator());
StringBuilder q = new StringBuilder(" where ");
String and = "";
// for all ground terms of l
for (int i = 0; i < l.getArity(); i++) {
Term t = l.getTerm(i);
if (t.isGround()) {
q.append(and);
String ts;
if (t.isstring()) {
ts = "'" + ((StringTerm) t).getString() + "'";
} else if (t.isNumeric()) {
ts = t.toString();
} else {
ts = "'" + t.toString() + "'";
}
q.append(Meta.getColumnName(i + 1) + " = " + ts);
and = " and ";
}
}
if (isCreatedByJason(l.getPredicateIndicator())) {
q.append(and + COL_NEG + " = " + l.negated());
}
//System.out.println(q.toString());
if (and.length() > 0) // add nothing in the clausule
return q.toString();
else
return "";
}
/**
* Tests fix for Bug#23212347,ALL API CALLS ON RESULTSET MetaDATA RESULTS IN NPE WHEN USESERVERPREPSTMTS=TRUE.
*/
public void testBug23212347() throws Exception {
boolean useSPS = false;
do {
String testCase = String.format("Case [SPS: %s]",useSPS ? "Y" : "N");
createTable("testBug23212347","(id INT)");
Properties props = new Properties();
props.setProperty("useServerPrepStmts",Boolean.toString(useSPS));
Connection testConn = getConnectionWithProps(props);
Statement testStmt = testConn.createStatement();
testStmt.execute("INSERT INTO testBug23212347 VALUES (1)");
this.pstmt = testConn.prepareStatement("SELECT * FROM testBug23212347 WHERE id = 1");
this.rs = this.pstmt.executeQuery();
assertTrue(testCase,this.rs.next());
assertEquals(testCase,this.rs.getInt(1));
assertFalse(testCase,this.rs.next());
ResultSetMetaData rsmd = this.pstmt.getMetaData();
assertEquals(testCase,"id",rsmd.getColumnName(1));
this.pstmt = testConn.prepareStatement("SELECT * FROM testBug23212347 WHERE id = ?");
this.pstmt.setInt(1,1);
this.rs = this.pstmt.executeQuery();
assertTrue(testCase,this.rs.getInt(1));
assertFalse(this.rs.next());
rsmd = this.pstmt.getMetaData();
assertEquals(testCase,rsmd.getColumnName(1));
} while (useSPS = !useSPS);
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。