<%@ page language="java" contentType="text/html; charset=ISO-8859-1" pageEncoding="ISO-8859-1"%>
<%@ page import="java.sql.*,mongodb.jdbc.MongoStatement" %>
MongoDB Query with JSP Example
<%
Class.forName("mongodb.jdbc.MongoDriver");
// Connect to the URL. The last part is the database name (tpch in this case).
String url="jdbc:mongo://server/tpch?rebuildschema=false";
Connection con = null;
String sql;
try
{
con = DriverManager.getConnection(url, "dbuser", "dbuser");
MongoStatement stmt = (MongoStatement) con.createStatement();
sql = "SELECT _id, n_nationkey, n_name, n_regionkey FROM nation WHERE n_name >= 'C';";
ResultSet rst = stmt.executeQuery(sql);
out.println("SQL query
"+sql+"
");
// Note: MongoStatement.getQueryString() only returns a Mongo query string if the entire query is executed on MongoDB.
out.println("Executed Mongo query
"+((MongoStatement) stmt).getQueryString()+"
");
// Print out your results
ResultSetMetaData meta = rst.getMetaData();
int numColumns = meta.getColumnCount();
out.print("");
out.print("| "+meta.getColumnName(1)+" | ");
for (int j = 2; j <= meta.getColumnCount(); j++)
out.print(""+ meta.getColumnName(j)+" | ");
out.println("
");
int count = 0;
while (rst.next())
{
out.print("| "+rst.getObject(1)+" | ");
for (int j = 2; j <= numColumns; j++)
out.print("" + rst.getObject(j)+" | ");
out.println("
");
count++;
}
out.println("Total results: "+count+"
");
}
catch (Exception ex)
{
out.println("Exception: " + ex);
ex.printStackTrace();
}
finally
{
if (con != null)
{
try
{
// Close the connection
con.close();
}
catch (SQLException ex)
{
out.println("SQLException: " + ex);
}
}
}
%>