<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
<%@ page import="java.sql.*" %>
<%@ page import="java.io.*" %>
<%@ page import="javax.naming.*" %>
<%@ page import="javax.sql.*" %>

<%!
/**
 * @File Name : webservice.jsp
 * @Description : xFrame 웹 서비스 프로젝트 서비스 JSP
 * @Modification Information
 * @
 * @  수정일                          수정내용
 * @ ---------   ---------   -------------------------------
 * @ 2018.09.03     최초생성
 * @ 2020.10.06     수정배포
 * @ 2021.09.02     수정배포    MYSQL DB 연결 정보 문자열 오류 수정 및 소스 정렬 수정
 *
 * @author 소프트베이스 솔루션 개발팀
 * @since 2018. 09. 03
 * @version 1.0
 * @see
 *	
 *  Copyright (C) by Softbase All right reserved.
 */
%>

<%!
	// 데이터에 쌍따옴표로 묶여 있는경우 제거
	public static String fnRemoveDobubleQuot(String strString) {
		if (strString == null || strString.contentEquals("")) {
			return strString;
		}
		if (strString.substring(0, 1).contentEquals("\"")) {
			strString = strString.substring(1, strString.length());
		}
		if (strString.substring(strString.length() - 1, strString.length()).contentEquals("\"")) {
			strString = strString.substring(0, strString.length() - 1);
		}
		return strString;
	}
	
	// 숫자를 bytearray 4byte로 변환
	public static byte[] getByteArrayFromInt(int nValue) {
		byte[] baBuff = new byte[4];
		baBuff[0] = (byte)((nValue & 0xff000000) / 0x1000000);		
		baBuff[1] = (byte)((nValue & 0x00ff0000) / 0x10000);
		baBuff[2] = (byte)((nValue & 0x0000ff00) / 0x100);
		baBuff[3] = (byte)(nValue & 0x000000ff);
		return baBuff;
	}

	// 데이터 전송 
	public static void fnWriteOneFieldData(OutputStream outStream, String strData, String strCharSet) {
		try {
			byte[] baData = strData.getBytes(strCharSet);
			int nDataLength = baData.length;
			// 데이터 길이(4byte)
			outStream.write(getByteArrayFromInt(baData.length), 0, 4);			
			// 데이터
			outStream.write(baData, 0, nDataLength);
		} 
		catch (Exception e) {
			
		}
	}
	
	// 파라미터값에서 한글이 깨지는 경우, 파라미터 코드 변환용 함수
	public static String asc2kscUTF8(String asc) throws UnsupportedEncodingException {
		if(asc == null) 
			return null;
		return new String(asc.getBytes("ISO-8859-1"), "UTF-8");
	}		
%>

<%
	//Dev@Studio에서 데이터 처리 시 사용하는 구분자
	final byte		DATASTART_DEL = 0x03;		//데이터 시작
	final byte		DATAEND_DEL   = 0x03;		//데이터 끝
	final String	S_CHARSET     = "UTF-8";
	
	Connection 			conn = null;		// DB Connection Object
	PreparedStatement 	pstmt = null;		// JDBC PreparedStatement Object
	ResultSet 			rs = null;	 		// Query Result Set Object
	ResultSetMetaData 	rsMetaData = null;	
	
	//Jsp Servlet 기본 out 객체 초기화(java class 파일에서는 필요하지않음)
	out.clear(); 
	out = pageContext.pushBody();
	
	try {
		// DATABASE 접속 설정.(접속할  DATABASE 환경에 맞게 수정하여 사용)
		// Case1. JDBC 연결 방식
		
		/* ORACLE */
		String strDBServiceName = "orcl";
		String strDatabaseNm = "ORACLE";
		String strDriverClass = "oracle.jdbc.driver.OracleDriver";
		String strDBUrl = "jdbc:oracle:thin:@127.0.0.1:1521:" + strDBServiceName;
		String strDBUserID = "xframe";
		String strDBUserPWD = "xframe"; 
		
		/* MYSQL
		String strDBServiceName = "xframe";
		String strDatabaseNm = "MYSQL";
		String strDriverClass = "com.mysql.jdbc.Driver";
		String strDBUrl = "jdbc:mysql://127.0.0.1:3306/" + strDBServiceName + "?useUnicode=true&characterEncoding=utf8";
		String strDBUserID = "xframe";
		String strDBUserPWD = "xframe"; 
		*/
		
		/* MariaDB
		String strDBServiceName = "xframe";
		String strDatabaseNm = "MARIADB";
		String strDriverClass = "org.mariadb.jdbc.Driver";
		String strDBUrl = "jdbc:mariadb://127.0.0.1:3306/" + strDBServiceName;
		String strDBUserID = "xframe";
		String strDBUserPWD = "xframe"; 
		*/
		
		/* DB2 
		String strDBServiceName = "dev2db";
		String strDatabaseNm = "DB2";
		String strDriverClass = "com.ibm.db2.jcc.DB2Driver";
		String strDBUrl = "jdbc:db2://127.0.0.1:50000/" + strDBServiceName;
		String strDBUserID = "xframe";
		String strDBUserPWD = "xframe"; 
		*/
		
		/* MS-SQL
		String strDBServiceName = "xframe";
		String strDatabaseNm = "MS-SQL";
		String strDriverClass = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
		String strDBUrl = "jdbc:sqlserver://127.0.0.1:1433,databaseName=" + strDBServiceName;
		String strDBUserID = "xframe";
		String strDBUserPWD = "xframe"; 
		*/

		/* JDBC 연결 */
		Class.forName(strDriverClass);
		conn = DriverManager.getConnection(strDBUrl, strDBUserID, strDBUserPWD);
		
	    /* Case2. DBCP JNDI 방식 
	    Context context = new InitialContext();
	    DataSource dataSource = (DataSource) context.lookup("java:comp/env/jdbc/oracle"); // WAS JNDI 이름으로 변경
	    conn = dataSource.getConnection(); 
	    String strDatabaseNm = "ORACLE";
	    String strDBServiceName = "orcl";
	    */

	    // 결과 전송을 위한 스트림 객체 생성
		OutputStream outStream = response.getOutputStream();
	    //PrintWriter outWriter = response.getWriter();

		// 데이터 시작 표시
		outStream.write(DATASTART_DEL);

		// 파라미터중 command값을 읽어들인다.
		String strCommand = request.getParameter("command");
		
		// 앞뒤에 쌍따옴표 있으면 제거
		strCommand = fnRemoveDobubleQuot(strCommand);
		
		// command 처리. command는 3가지중 하나. (open, select, execute)
		if (strCommand.contentEquals("open")) {
			// 데이터베이스에 연결된 결과를 반환.
			if (conn == null) {
				// 성공/실패여부
				// 로그 System.out.println("[xFrame WebService] " + strDatabaseNm +" Connection is null : Database 접속 실패.");
				outStream.write("0".getBytes(S_CHARSET));
				// 에러 메세지
				outStream.write("open fail".getBytes(S_CHARSET));
			} 
			else {
				// open에 대한 결과 데이터 - 성공실패여부(1,0) + DB종류 + 접속한 oracle serivce명
				// - DB종류 : "ORACLE", "MYSQL", "MS-SQL", "DB2", "TIBERO"
				// 성공/실패여부
				// 로그 System.out.println("[xFrame WebService] " + strDatabaseNm +" Connection is Success.");
				outStream.write("1".getBytes(S_CHARSET));
				// 필드 갯수
				outStream.write(getByteArrayFromInt(2), 0, 4);
				// DB종류 전송
				fnWriteOneFieldData(outStream, strDatabaseNm, S_CHARSET);
				// 접속한 Database serivce명 전송
				fnWriteOneFieldData(outStream, strDBServiceName, S_CHARSET);
			}
		} 
		else if (strCommand.contentEquals("select")) {
			// select할 쿼리문을 읽어들인다.
			String strQuery = request.getParameter("query");
			if (strQuery != null && !strQuery.contentEquals("")) {
				strQuery = fnRemoveDobubleQuot(strQuery);
			}
			
			// 쿼리 실행
			pstmt = conn.prepareStatement(strQuery);
			rs = pstmt.executeQuery();
			// 결과 데이터 확인
			rsMetaData = rs.getMetaData();
			
			// 성공여부 전송 (성공:1, 실패:0)
			outStream.write("1".getBytes(S_CHARSET));
			// 필드 갯수 전송
			outStream.write(getByteArrayFromInt(rsMetaData.getColumnCount()), 0, 4);
			// 레코드단위 필드 단위로 데이터 조립
			for (int nRow = 0; rs.next(); nRow++) {
				for (int nCol = 1; nCol <= rsMetaData.getColumnCount(); nCol++) {
					String strData = rs.getString(nCol);
					if (strData == null) {
						strData = "";
					}
					// 데이터 전송
					fnWriteOneFieldData(outStream, strData, S_CHARSET);
				}
			}
		} 
		else if (strCommand.contentEquals("execute")) {
			// execute할 쿼리문을 읽어들인다.
			String strQuery = request.getParameter("query");
			
			if(strQuery != null && !strQuery.contentEquals("")) {
				strQuery = fnRemoveDobubleQuot(strQuery);
			}
			// 쿼리 실행
			pstmt = conn.prepareStatement(strQuery);
			// clob데이터가 전달되었는지 확인하고 처리.
			// clob데이터 개수를 먼저 읽어들이고 개수만큼 clob데이터를 읽어 들인다.
			String strCLOBCount = request.getParameter("clobcount");
			strCLOBCount = fnRemoveDobubleQuot(strCLOBCount);
			
			if (strCLOBCount != null && !strCLOBCount.contentEquals("")) {
				int nCLOBCount = Integer.parseInt(strCLOBCount);
				// clob데이터 파라미터 이름은 clobdata0, clobdata1, clobdata2.. 순으로 전달받음.
				String strCLOBData;
				String strCLOBParam;
				for (int nCount = 0;nCount < nCLOBCount;nCount++) {
					strCLOBParam = "clobdata" + Integer.toString(nCount);
					strCLOBData = request.getParameter(strCLOBParam);
					if (strCLOBData == null) {
						strCLOBData = "";
					}
					if (!strCLOBData.contentEquals("")) {
						strCLOBData = fnRemoveDobubleQuot(strCLOBData);
					}
					pstmt.setCharacterStream(nCount + 1 , new StringReader(strCLOBData), strCLOBData.length());
				}
			}
			
			int nRet = pstmt.executeUpdate();
			// 성공/실패 여부 전송
			if (-1 < nRet) {
				// 성공/실패여부, 성공
				outStream.write("1".getBytes(S_CHARSET));		
			} 
			else {
				// 성공/실패여부, 실패
				outStream.write("0".getBytes(S_CHARSET));
				// 에러 메세지
				outStream.write("execute fail".getBytes(S_CHARSET));
			}
		} 
		else {
			// command(open, select, execute) 가 아닐경우 에러 처리
			outStream.write("0".getBytes(S_CHARSET));
			// 에러 메세지
			outStream.write("알 수 없는 command입니다. 관리자에게 문의하세요.".getBytes(S_CHARSET));
		}
		
		//  데이터 끝 표시
		outStream.write(DATAEND_DEL);	
		
		outStream.flush();
		outStream.close();
	} 
	catch (Exception e) {
		// outputstream에 데이터를 쓰는 중간에 오류가 나면  response를 reset한 후 에러메세지 전송.
		response.reset();
		
		OutputStream outStream = response.getOutputStream();
		// 데이터 시작 표시
		outStream.write(DATASTART_DEL);
		// 실패 코드 설정
		outStream.write("0".getBytes(S_CHARSET));
		// 에러메세지 설정
		outStream.write(e.getMessage().getBytes(S_CHARSET));
		// 데이터 끝 표시
		outStream.write(DATAEND_DEL);	
		
		outStream.flush();
		outStream.close();	
		
		// 콘솔 에러 메세지 출력
		e.printStackTrace();
	}
	finally {
		// Release a database resources
		try { 
			if (rs != null) {
				rs.close(); 
			}
			if (pstmt != null) { 
				pstmt.close(); 
			}
			if (conn != null) {
				conn.close(); 
			}			
		} 
		catch (Exception ignore) {}
	}
%>