package com.maiden.hive.portlet;

import org.osgi.service.component.annotations.Component;

import javax.portlet.*;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.*;

@Component(
	immediate = true,
	property = {
		"com.liferay.portlet.display-category=category.sample",
		"com.liferay.portlet.instanceable=true",
		"javax.portlet.display-name=hive.portlet Portlet",
		"javax.portlet.security-role-ref=power-user,user"
	},
	service = Portlet.class
)
public class HivePortlet extends GenericPortlet {

	private PrintWriter printWriter;

	@Override
	protected void doView(
			RenderRequest renderRequest, RenderResponse renderResponse)
		throws IOException, PortletException {

		printWriter = renderResponse.getWriter();

		try {
			/*
			XmlNews x = XmlNewsLocalServiceUtil.fetchXmlNews(44234897);
			if (x == null) {
				System.out.println("X IS NULL");
			} else {
				System.out.println("X: " + x.getTitle());
			}
			*/
			//List<XmlNews> news = getService().getXmlNewses(0, 1);
			//System.out.println("SIZE: " + news.size());
		} catch (Exception e) {
			e.printStackTrace();
		}

		tryHive();

		printWriter.print("hive.portlet Portlet - Hello World 222!");
	}

	private void tryHive() {

		printWriter.print("HELLO WORLD");

		Class clazz = org.apache.hive.jdbc.HiveDriver.class;

		// JDBC driver name and database URL
		final String JDBC_DRIVER = "org.apache.hive.jdbc.HiveDriver";
		final String DB_URL = "jdbc:hive2://10.5.30.2:10000/default";

		//  Database credentials
		final String USER = "dsservice";
		final String PASS = "";

		Connection conn = null;
		Statement stmt = null;
		try{
			//STEP 2: Register JDBC driver
			Class.forName(JDBC_DRIVER);

			//STEP 3: Open a connection
			printWriter.print("Connecting to database...");
			conn = DriverManager.getConnection(DB_URL,USER,PASS);

			//STEP 4: Execute a query
			printWriter.print("Creating statement...");
			stmt = conn.createStatement();
			String sql;
			sql = "SELECT xmlnews.identifier, xmlnews.title FROM snl_test.xmlnews limit 10";
			ResultSet rs = stmt.executeQuery(sql);

			//STEP 5: Extract data from result set
			while(rs.next()){
				//Retrieve by column name
				long id  = rs.getLong("xmlnews.identifier");
				String first = rs.getString("xmlnews.title");

				//Display values
				printWriter.print("ID: " + id);
				printWriter.print(", First: " + first);
			}
			//STEP 6: Clean-up environment
			rs.close();
			stmt.close();
			conn.close();
		}catch(SQLException se){
			//Handle errors for JDBC
			se.printStackTrace();
		}catch(Exception e){
			//Handle errors for Class.forName
			e.printStackTrace();
		}finally{
			//finally block used to close resources
			try{
				if(stmt!=null)
					stmt.close();
			}catch(SQLException se2){
			}// nothing we can do
			try{
				if(conn!=null)
					conn.close();
			}catch(SQLException se){
				se.printStackTrace();
			}//end finally try
		}//end try
	}

	private void tryMySQL() {

		Connection conn = null;
		Statement stmt = null;
		try{
			//STEP 2: Register JDBC driver
			Class.forName("com.mysql.jdbc.Driver");

			//STEP 3: Open a connection
			System.out.println("Connecting to database...");
			conn = DriverManager.getConnection("jdbc:mysql://localhost/liferay-dxp-sp4", "liferay", "password");

			//STEP 4: Execute a query
			System.out.println("Creating statement...");
			stmt = conn.createStatement();
			String sql;
			sql = "SELECT userid, screenname FROM USER_";
			ResultSet rs = stmt.executeQuery(sql);

			//STEP 5: Extract data from result set
			while(rs.next()){
				//Retrieve by column name
				long id  = rs.getLong("userid");
				String screenname = rs.getString("screenname");

				//Display values
				System.out.print("ID: " + id);
				System.out.print(", Name: " + screenname);
			}
			//STEP 6: Clean-up environment
			rs.close();
			stmt.close();
			conn.close();
		}catch(SQLException se){
			//Handle errors for JDBC
			se.printStackTrace();
		}catch(Exception e){
			//Handle errors for Class.forName
			e.printStackTrace();
		}finally{
			//finally block used to close resources
			try{
				if(stmt!=null)
					stmt.close();
			}catch(SQLException se2){
			}// nothing we can do
			try{
				if(conn!=null)
					conn.close();
			}catch(SQLException se){
				se.printStackTrace();
			}//end finally try
		}//end try
	}
}