CarreraProfesionalMysqlDAO.java 4.76 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
package trismegistoplanilla.mysqldao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONArray;
import org.json.JSONObject;
import trismegistoplanilla.beans.CarreraProfesionalBean;
import trismegistoplanilla.dao.CarreraProfesionalDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;

public class CarreraProfesionalMysqlDAO implements CarreraProfesionalDAO {

	@Override
	public JSONObject listarCarreraProfesional(String carrera) {
18
		System.out.println("CarreraProfesionalMysqlDAO: listarCarreraProfesional");
19 20 21 22 23 24 25
		JSONObject jsonListarCarreraProfesional = new JSONObject();
		JSONArray jsonArrayListarCarreraProfesional = new JSONArray();
		PreparedStatement ps = null, psCount = null;
		ResultSet rs = null, rsCount = null;
		Connection connection = null;
		int total_count = 0;
		try {
26
			connection = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91
			String sql
				= "select "
				+ "codigo_carrera_profesional codigoCarreraProfesional, "
				+ "nombre nombre, "
				+ "estado_registro estadoRegistro "
				+ "FROM carrera_profesional "
				+ "where estado_registro = 1 and codigo_carrera_profesional != 404 and nombre like ?";
			ps = connection.prepareStatement(sql);
			ps.setString(1, carrera + "%");
			rs = ps.executeQuery();
			while (rs.next()) {
				CarreraProfesionalBean carreraProfesional = new CarreraProfesionalBean();
				carreraProfesional.setId(rs.getInt("codigoCarreraProfesional"));
				carreraProfesional.setCodigoCarreraProfesional(rs.getInt("codigoCarreraProfesional"));
				carreraProfesional.setNombre(rs.getString("nombre"));
				carreraProfesional.setEstado_registro(rs.getInt("estadoRegistro"));
				JSONObject jsonObjCarreraProfesional = new JSONObject(carreraProfesional);
				jsonArrayListarCarreraProfesional.put(jsonObjCarreraProfesional);
			}

			// count result search
			String sqlCount = ""
				+ "select "
				+ "count(1) total_count "
				+ "from carrera_profesional "
				+ "where estado_registro = 1 and nombre like ?";
			psCount = connection.prepareStatement(sqlCount);
			psCount.setString(1, carrera + "%");
			rsCount = psCount.executeQuery();
			rsCount.next();
			total_count = rsCount.getInt("total_count");
		} catch (SQLException e) {
			e.printStackTrace();
			jsonListarCarreraProfesional.put("status", false);
			jsonListarCarreraProfesional.put("message", "Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (rsCount != null) {
					rs.close();
				}
				if (ps != null) {
					ps.close();
				}
				if (psCount != null) {
					psCount.close();
				}
				if (connection != null) {
					connection.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

		jsonListarCarreraProfesional.put("total_count", total_count);
		jsonListarCarreraProfesional.put("incomplete_results", false);
		jsonListarCarreraProfesional.put("items", jsonArrayListarCarreraProfesional);
		return jsonListarCarreraProfesional;
	}

	@Override
	public JSONObject validarExistenciaCarreraProfesional(CarreraProfesionalBean carreraProfesional) {
92
		System.out.println("CarreraProfesionalMysqlDAO: validarExistenciaCarreraProfesional");
93 94 95 96 97 98 99
		JSONObject jsonValidarExistenciaCarreraProfesional = null;
		ResponseHelper response = new ResponseHelper();
		int existeCarreraProfesional = 0;
		Connection connection = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		try {
100
			connection = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141
			String sql
				= "select "
				+ "count(1) as existeCarreraProfesional "
				+ "from carrera_profesional "
				+ "where codigo_carrera_profesional = ? and estado_registro = 1";
			ps = connection.prepareStatement(sql);
			ps.setInt(1, carreraProfesional.getCodigoCarreraProfesional());
			rs = ps.executeQuery();
			rs.next();
			existeCarreraProfesional = rs.getInt("existeCarreraProfesional");
			if (existeCarreraProfesional > 0) {
				response.setStatus(true);
				response.setMessage("La carrera profesional seleccionada existe.");
			} else {
				response.setStatus(false);
				response.setMessage("La carrera profesional seleccionada no existe.");
			}
		} catch (SQLException e) {
			e.printStackTrace();
			response.setStatus(false);
			response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (ps != null) {
					ps.close();
				}
				if (connection != null) {
					connection.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		jsonValidarExistenciaCarreraProfesional = new JSONObject(response);
		return jsonValidarExistenciaCarreraProfesional;
	}

}