<%@page session="false" import="javax.sql.DataSource,
org.apache.commons.lang.StringEscapeUtils, oracle.jdbc.OracleDriver" %>
<%@ page import="com.day.commons.datasource.poolservice.DataSourceNotFoundException" %>
<%@ page import="com.day.commons.datasource.poolservice.DataSourcePool, javax.jcr.query.Query" %>
<%@ page import="javax.sql.DataSource" %>
<%@ page import="java.sql.Connection" %>
<%@ page import="java.sql.SQLException" %>
<%@ page import="java.sql.Statement" %>
<%@ page import="java.sql.ResultSet, java.sql.ResultSetMetaData" %>
<%@page import="com.day.cq.commons.jcr.JcrUtil, org.apache.commons.lang.StringEscapeUtils"%>
<%@include file="/libs/wcm/global.jsp" %>
Database Import
<%
Node node = resource.adaptTo(Node.class);
Session s = node.getSession();
String action = request.getParameter("action");
if (action == null) {
%>
<% } else if ("create".equals(action)) {
out.write("
*******START");
DataSource ds = null;
String dataSourceName = request.getParameter("dataSourceName");
String sStatement = request.getParameter("cmd");
DataSourcePool dbService = sling.getService(DataSourcePool.class);
out.write("
Getting dbService : " + dbService);
try {
out.write("
Getting DataSource.. ");
ds = (DataSource) dbService.getDataSource(dataSourceName);
} catch(Exception e) {
out.write("
Exception while getting DataSource :: "+ dataSourceName + " ::
******
" + e.fillInStackTrace() + "
******
");
}
if(ds != null) {
%>
Found DataSource <%=dataSourceName%>.
<%
if(sStatement != null) {
try {
Class.forName("oracle.jdbc.OracleDriver", true,
super.getClass().getClassLoader());
final Connection connection = ds.getConnection();
final Statement statement = connection.createStatement();
final ResultSet resultSet = statement.executeQuery(sStatement);
ResultSetMetaData rsmd = resultSet.getMetaData();
int numColumns = rsmd.getColumnCount();
out.write("
connection : " + connection);
out.write("
resultSet : " + resultSet);
// Here goes additional processing of this data for example, store this data to CRX nodes
} catch (Exception e) {
out.write("
Exception while getting connection: ::
******
" + e.fillInStackTrace() + "
******
");
}
}
} else out.write("
DataSource is null :: " + ds);
out.write("
*******END");
}
%>