Example usage for java.sql Statement executeQuery

Posted on by mtoplistChuyên mục:Top List

Introduction

In this page you can find the example usage for java.sql Statement executeQuery.

Prototype

ResultSet executeQuery(String sql) 
throws
 SQLException;

In this page you can find the example usage for java.sql Statement executeQuery.

Source Link

Document

Executes the given SQL statement, which returns a single ResultSet object.

Usage

Executes the given SQL statement, which returns a singleobject.

From source file:TestDB.java

 
/**
 * Runs a test by creating a table, adding a value, showing the table contents, and removing the
 * table.
/
/
f
r
o
m
 
 
w
 
 
w
 
w
 
.
j
 
 
a
 
 
v
 
a
 
2
s
 
 
.
 
 
c
o
 
 
m

 */

public
 
static
 
void
 runTest() 
throws
 SQLException, IOException
{
   Connection conn = getConnection();
   
try

   {

      Statement stat = conn.createStatement();


      stat.executeUpdate(
"CREATE TABLE Greetings (Message CHAR(20))"
);
      stat.executeUpdate(
"INSERT INTO Greetings VALUES ('Hello, World!')"
);


      ResultSet result = stat.executeQuery(
"SELECT * FROM Greetings"
);
      
if
 (result.next())
         System.out.println(result.getString(1));
      result.close();
      stat.executeUpdate(
"DROP TABLE Greetings"
);
   }
   
finally

   {
      conn.close();
   }
}

From source file:com.oracle.tutorial.jdbc.FilteredRowSetSample.java

public
 
static
 
void
 viewTable(Connection con) 
throws
 SQLException {

    Statement stmt = null;

    String query = 
"select * from COFFEE_HOUSES"
;
    
try
 {
/
*
f
r
o
m
 
 
w
 
 
w
w
 
 
.
 
j
 
a
 
 
v
 
a
 
 
2
s
 
.
 
c
o
 
m
*
/

        stmt = con.createStatement();


        ResultSet rs = stmt.executeQuery(query);


        
while
 (rs.next()) {
            System.out.println(rs.getInt(
"STORE_ID"
) + 
", "
 + rs.getString(
"CITY"
) + 
", "
 + rs.getInt(
"COFFEE"
)
                    + 
", "
 + rs.getInt(
"MERCH"
) + 
", "
 + rs.getInt(
"TOTAL"
));
        }

    } 
catch
 (SQLException e) {
        JDBCTutorialUtilities.printSQLException(e);
    } 
finally
 {
        
if
 (stmt != null) {
            stmt.close();
        }
    }
}

From source file:Main.java

public
 
static
 String QueryVcTable2(Statement stmt, String app_name) {
    String sql_1 = 
"SELECT app_versioncode FROM app_info.`msp_table_8.12_copy` WHERE app_name='"
 + app_name
            + 
"'"
;
    ResultSet result = null;
/
/
f
r
o
m
 
 
 
w
w
 
w
 
 
.
 
 
j
 
 
a
 
v
a
 
 
2
 
 
s
 
.
 
c
o
 
 
m

    String v = null;
    
try
 {

        result = stmt.executeQuery(sql_1);

        
while
 (result.next()) {
            v = result.getString(1);
        }
        
if
 (v != null)
            
return
 v;
    } 
catch
 (SQLException e) {
        e.printStackTrace();
    }
    
return
 null;
}

From source file:com.nokia.helium.metadata.DerbyFactoryManagerCreator.java

/**
 * Checks the database integrity.
/
/
f
r
o
m
 
 
 
w
 
 
w
 
 
w
 
.
j
a
 
v
 
 
a
 
 
2
 
 
s
 
 
.
c
o
 
m

 * @param urlPath - database path to be connected to.
 * @return boolean - true if db is valid false otherwise.
 */

private
 
static
 
boolean
 checkDatabaseIntegrity(File database) 
throws
 MetadataException {
    
boolean
 result = false;
    Connection connection = null;
    
try
 {
        connection = DriverManager.getConnection(
"jdbc:derby:"
 + database);
        
if
 (connection != null) {

            Statement stmt = connection.createStatement();


            ResultSet rs = stmt.executeQuery(
"select version from version"
);
            
int
 version = -1;
            
if
 (rs.next()) {
                version = rs.getInt(1);
            }
            rs.close();
            stmt.close();
            connection.close();
            connection = null;
            result = version == Version.DB_VERSION;
        }
    } 
catch
 (SQLException ex) {
        
try
 {
            DriverManager.getConnection(
"jdbc:derby:;shutdown=true"
);
        } 
catch
 (java.sql.SQLException sex) {
            
// normal exception during database shutdown

            connection = null;
        }
        
return
 false;
    } 
finally
 {
        
try
 {
            
if
 (connection != null) {
                connection.close();
            }
        } 
catch
 (java.sql.SQLException sex) {
            
// normal exception during database shutdown

            connection = null;
        }
        connection = null;
        
if
 (!result) {
            
try
 {
                DriverManager.getConnection(
"jdbc:derby:;shutdown=true"
);
            } 
catch
 (java.sql.SQLException sex) {
                
// normal exception during database shutdown

                connection = null;
            }
        }
    }
    
//shutdown unloads the driver, driver need to be loaded again.

    
return
 result;
}

From source file:net.tirasa.ilgrosso.resetdb.Main.java

private
 
static
 
void
 resetOracle(
final
 Connection conn) 
throws
 Exception {


    
final
 Statement statement = conn.createStatement();


    ResultSet resultSet = statement.executeQuery(

            
"SELECT 'DROP VIEW ' || object_name || ';'"
 + 
" FROM user_objects WHERE object_type='VIEW'"
);
    
final
 List<String> drops = 
new
 ArrayList<String>();
    
while
 (resultSet.next()) {
        drops.add(resultSet.getString(1));
    }
/
/
f
r
o
m
 
w
 
w
w
 
.
 
j
a
 
v
 
 
a
 
2
s
 
 
.
c
 
 
o
 
m

    resultSet.close();

    
for
 (String drop : drops) {
        statement.executeUpdate(drop.substring(0, drop.length() - 1));
    }
    drops.clear();

    resultSet = statement.executeQuery(
"SELECT 'DROP INDEX ' || object_name || ';'"

            + 
" FROM user_objects WHERE object_type='INDEX'"
 + 
" AND object_name NOT LIKE 'SYS_%'"
);
    
while
 (resultSet.next()) {
        drops.add(resultSet.getString(1));
    }
    resultSet.close();

    
for
 (String drop : drops) {
        
try
 {
            statement.executeUpdate(drop.substring(0, drop.length() - 1));
        } 
catch
 (SQLException e) {
            LOG.error(
"Could not perform: {}"
, drop);
        }
    }
    drops.clear();

    resultSet = statement.executeQuery(
"SELECT 'DROP TABLE ' || table_name || ' CASCADE CONSTRAINTS;'"

            + 
" FROM all_TABLES WHERE owner='"
 + ((String) ctx.getBean(
"username"
)).toUpperCase() + 
"'"
);
    
while
 (resultSet.next()) {
        drops.add(resultSet.getString(1));
    }
    resultSet.close();

    resultSet = statement
            .executeQuery(
"SELECT 'DROP SEQUENCE ' || sequence_name || ';'"
 + 
" FROM user_SEQUENCES"
);
    
while
 (resultSet.next()) {
        drops.add(resultSet.getString(1));
    }
    resultSet.close();

    
for
 (String drop : drops) {
        statement.executeUpdate(drop.substring(0, drop.length() - 1));
    }

    statement.close();
    conn.close();
}

From source file:com.l2jfree.sql.L2DatabaseInstaller.java

private
 
static
 
double
 getDatabaseRevision() {
    
double
 revision = -1;

    Connection con = null;
/
*
 
 
w
 
 
w
w
 
.
j
a
v
a
2
 
s
 
.
 
 
c
 
o
 
 
m
*
/

    
try
 {
        con = L2Database.getConnection();


        Statement st = con.createStatement();


        ResultSet rs = st.executeQuery(
"SELECT revision FROM _revision ORDER BY revision DESC LIMIT 1"
);

        
if
 (rs.next())
            revision = rs.getDouble(1);

        rs.close();
        st.close();
    } 
catch
 (SQLException e) {
        e.printStackTrace();
    } 
finally
 {
        L2Database.close(con);
    }

    
return
 revision;
}

From source file:com.espertech.esperio.db.SupportDatabaseService.java

public
 
static
 Object[][] readAll(String tableName) 
throws
 SQLException {
    Connection connection = getConnection(PARTURL, DBUSER, DBPWD);
    connection.setAutoCommit(true);
/
/
f
r
o
m
 
w
w
w
.
j
a
 
v
 
a
 
 
2
 
s
 
.
 
c
o
 
 
m


    Statement stmt = connection.createStatement();

    String sql = 
"select * from "
 + tableName;
    log.info(
"Executing sql : "
 + sql);

    ResultSet resultSet = stmt.executeQuery(sql);


    List<Object[]> rows = 
new
 ArrayList<Object[]>();
    
while
 (resultSet.next()) {
        List<Object> row = 
new
 ArrayList<Object>();
        
for
 (
int
 i = 0; i < resultSet.getMetaData().getColumnCount(); i++) {
            row.add(resultSet.getObject(i + 1));
        }
        rows.add(row.toArray());
    }

    Object[][] arr = 
new
 Object[rows.size()][];
    
for
 (
int
 i = 0; i < rows.size(); i++) {
        arr[i] = rows.get(i);
    }

    stmt.close();
    connection.close();
    
return
 arr;
}

From source file:massbank.svn.SVNUtils.java

/**
 *
 */
/
*
w
 
 
w
 
 
w
 
 
.
 
j
 
 
a
 
 
v
a
 
2
 
s
 
.
 
 
c
o
 
 
m
*
/


public
 
static
 
boolean
 checkDBExists(String dbName) {
    
if
 (dbName.equals(
""
)) {
        
return
 false;
    }
    Connection con = connectDB(dbName);
    
if
 (con == null) {
        
return
 false;
    }
    
try
 {

        Statement stmt = con.createStatement();

        String sql = 
"SHOW TABLES LIKE 'SPECTRUM'"
;

        ResultSet rs = stmt.executeQuery(sql);

        String 
val
 = 
""
;
        
if
 (rs.first()) {
            
val
 = rs.getString(1);
        }
        con.close();
        
if
 (!
val
.equals(
""
)) {
            
return
 true;
        } 
else
 {
            
return
 false;
        }
    } 
catch
 (Exception e) {
        e.printStackTrace();
        
return
 false;
    }
}

From source file:au.org.ala.layers.stats.ObjectsStatsGenerator.java

private
 
static
 
void
 updateBbox() {

    
try
 {
/
*
f
r
o
m
 
w
w
w
.
 
j
 
 
a
 
v
 
 
a
 
2
 
 
s
 
.
 
 
c
 
 
o
 
 
m
*
/

        Connection conn = getConnection();
        String sql = 
"SELECT pid from objects where bbox is null limit 200000;"
;
        logger.info(
"loading bbox ..."
);

        Statement s1 = conn.createStatement();


        ResultSet rs1 = s1.executeQuery(sql);


        LinkedBlockingQueue<String[]> data = 
new
 LinkedBlockingQueue<String[]>();
        
while
 (rs1.next()) {
            data.put(
new
 String[] { rs1.getString(
"pid"
) });
        }

        CountDownLatch cdl = 
new
 CountDownLatch(data.size());

        BboxThread[] threads = 
new
 BboxThread[CONCURRENT_THREADS];
        
for
 (
int
 j = 0; j < CONCURRENT_THREADS; j++) {
            threads[j] = 
new
 BboxThread(data, cdl, getConnection().createStatement());
            threads[j].start();
        }

        cdl.await();

        
for
 (
int
 j = 0; j < CONCURRENT_THREADS; j++) {
            threads[j].s.close();
            threads[j].interrupt();
        }
        
return
;
    } 
catch
 (Exception e) {
        logger.error(e.getMessage(), e);
    }
    
return
;
}

From source file:com.amazon.services.awsrum.utils.RedshiftUtils.java

/**
 * Helper method to determine if a table exists in the Redshift database
 * 
/
*
w
 
 
w
 
 
w
 
.
j
a
 
v
 
a
 
 
2
 
 
s
 
.
 
c
 
o
 
 
m
*
/

 * @param loginProperties
 *            A properties file containing the authentication credentials for the database
 * @param redshiftURL
 *            The JDBC URL of the Redshift database
 * @param tableName
 *            The table to check existence of
 * @return true if connection to the database is successful and the table exists, otherwise
 *         false
 */

public
 
static
 
boolean
 tableExists(Properties loginProperties, String redshiftURL, String tableName) {
    Connection conn = null;
    
try
 {
        conn = DriverManager.getConnection(redshiftURL, loginProperties);


        Statement stmt = conn.createStatement();


        stmt.executeQuery(
"SELECT * FROM "
 + tableName + 
" LIMIT 1;"
);
        stmt.close();
        conn.close();
        
return
 true;
    } 
catch
 (SQLException e) {
        LOG.error(e);
        
try
 {
            conn.close();
        } 
catch
 (Exception e1) {
        }
        
return
 false;
    }
}

mtoplist