[ADD] mysqldao

parent db87f819
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.AreaBean;
import trismegistoplanilla.beans.CargoBean;
import trismegistoplanilla.dao.AreaCargoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class AreaCargoMysqlDAO implements AreaCargoDAO {
@Override
public JSONObject obtenerAreaCargo(AreaBean a, CargoBean c) {
System.out.println("AreaCargoSqlserverDAO: obtenerAreaCargo");
JSONObject JOObtenerAreaCargo = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "codigo_area_cargo codigoAreaCargo "
+ "from area_cargo "
+ "where codigo_area = ? and codigo_cargo = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, a.getCodigoArea());
ps.setInt(2, c.getCodigoCargo());
rs = ps.executeQuery();
rs.next();
int codigoAreaCargo = rs.getInt("codigoAreaCargo");
if (codigoAreaCargo > 0) {
JSONObject objAreaCargo = new JSONObject();
objAreaCargo.put("getResultedKey", codigoAreaCargo);
response.setStatus(true);
response.setMessage("Se encontró el código");
response.setData(objAreaCargo);
} else {
response.setStatus(false);
response.setMessage("Error! no se ha podido encontrar el código area cargo");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOObtenerAreaCargo = new JSONObject(response);
return JOObtenerAreaCargo;
}
@Override
public JSONObject asignarAreaCargo(JSONObject datos) {
System.out.println("AreaCargoSqlserverDAO: asignarAreaCargo");
JSONObject jObject = null;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "";
int resultado = 0;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.AreaCargoTipoPagoBean;
import trismegistoplanilla.dao.AreaCargoTipoPagoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class AreaCargoTipoPagoMysqlDAO implements AreaCargoTipoPagoDAO {
@Override
public JSONObject obtenerAreaCargoTipoPago(AreaCargoTipoPagoBean actp) {
System.out.println("AreaCargoTipoPagoSqlserverDAO: obtenerAreaCargoTipoPago");
JSONObject JOObtenerAreaCargoTipoPago = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "codigo_area_cargo_tipo_pago codigoAreaCargoTipoPago "
+ "from area_cargo_tipo_pago "
+ "where codigo_area_cargo = ? and codigo_tipo_pago = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, actp.getCodigoAreaCargo());
ps.setInt(2, actp.getCodigoTipoPago());
rs = ps.executeQuery();
rs.next();
int codigoAreaCargoTipoPago = rs.getInt("codigoAreaCargoTipoPago");
if (codigoAreaCargoTipoPago > 0) {
JSONObject objAreaCargo = new JSONObject();
objAreaCargo.put("getResultedKey", codigoAreaCargoTipoPago);
response.setStatus(true);
response.setMessage("Se encontró el código");
response.setData(objAreaCargo);
} else {
response.setStatus(false);
response.setMessage("Error! no se ha podido encontrar el código area cargo");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOObtenerAreaCargoTipoPago = new JSONObject(response);
return JOObtenerAreaCargoTipoPago;
}
}
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.AreaBean;
import trismegistoplanilla.beans.SedeBean;
import trismegistoplanilla.dao.AreaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class AreaMysqlDAO implements AreaDAO {
@Override
public JSONObject listarArea(SedeBean s) {
System.out.println("AreaSqlserverDAO: listarArea");
JSONObject JObjectArea = null;
JSONArray JArrayArea = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "SELECT "
+ " sede_area.codigo_area codigoArea, "
+ " area.nombre nombre "
+ "FROM "
+ " sede_area "
+ "INNER JOIN dbo.area ON dbo.area.codigo_area = dbo.sede_area.codigo_area "
+ "WHERE "
+ " sede_area.estado_registro = 1 "
+ "AND area.estado_registro = 1 "
+ "AND sede_area.codigo_sede = ? "
+ "GROUP BY "
+ " sede_area.codigo_area, "
+ " area.nombre";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, s.getCodigoSede());
rs = ps.executeQuery();
while (rs.next()) {
AreaBean a = new AreaBean();
a.setCodigoArea(rs.getInt("codigoArea"));
a.setNombre(rs.getString("nombre"));
JSONObject objArea = new JSONObject(a);
JArrayArea.put(objArea);
}
JSONObject objArea = new JSONObject();
objArea.put("areas", JArrayArea);
response.setStatus(true);
response.setMessage("Las áreas se listaron correctamente");
response.setData(objArea);
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JObjectArea = new JSONObject(response);
return JObjectArea;
}
@Override
public JSONObject validarExistenciaArea(SedeBean s, AreaBean a) {
System.out.println("AreaSqlserverDAO: validarExistenciaArea");
JSONObject JObjectValidarExistenciaArea = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "count(1) existeArea "
+ "from sede_area "
+ "where sede_area.estado_registro = 1 and sede_area.codigo_sede = ? and sede_area.codigo_area = ?";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, s.getCodigoSede());
ps.setInt(2, a.getCodigoArea());
rs = ps.executeQuery();
rs.next();
int existeArea = 0;
existeArea = rs.getInt("existeArea");
if (existeArea > 0) {
response.setStatus(true);
response.setMessage("La área seleccionada existe");
} else {
response.setStatus(false);
response.setMessage("Error! La área seleccionada no existe");
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JObjectValidarExistenciaArea = new JSONObject(response);
return JObjectValidarExistenciaArea;
}
@Override
public JSONObject registrar(JSONObject datos) {
System.out.println("AreaSqlserverDAO: registrar");
JSONObject jObject = null;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "insert into area (nombre, estado_registro) values (?, 1)";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
cnx.setAutoCommit(false);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("area"));
resultado = ps.executeUpdate();
if (resultado == 1) {
cnx.commit();
response.setStatus(true);
response.setMessage("Se registro el área correctamente!");
} else {
cnx.rollback();
response.setStatus(false);
response.setMessage("No se puedo registrar el área");
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
@Override
public JSONObject editar(JSONObject datos) {
System.out.println("AreaSqlserverDAO: editar");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
@Override
public JSONObject estado(JSONObject datos) {
System.out.println("AreaSqlserverDAO: estado");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
@Override
public JSONObject validarNombreAdd(JSONObject datos) {
System.out.println("AreaSqlserverDAO: validarNombreAdd");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select count(1) cantidad "
+ "FROM area "
+ "where area.nombre = ?";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("area"));
rs = ps.executeQuery();
if (rs.next()) {
resultado = rs.getInt("cantidad");
if (resultado == 1) {
response.setStatus(false);
response.setMessage("Ya existe un área con ese nombre");
} else {
response.setStatus(true);
response.setMessage("Puede proceder a registrar el área");
}
} else {
response.setStatus(false);
response.setMessage("No se pudo encontrar el área");
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
@Override
public JSONObject validarNombreEdit(JSONObject datos) {
System.out.println("AreaSqlserverDAO: validarNombreEdit");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select count(1) "
+ "FROM area "
+ "where area.nombre = ? "
+ "and area.codigo_area not in (?)";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("area"));
ps.setInt(2, datos.getInt("codigoArea"));
rs = ps.executeQuery();
if (rs.next()) {
resultado = rs.getInt("cantidad");
if (resultado == 1) {
response.setStatus(false);
response.setMessage("Ya existe un área con ese nombre");
} else {
response.setStatus(true);
response.setMessage("Puede proceder a actualizar el área");
}
} else {
response.setStatus(false);
response.setMessage("No se pudo encontrar el área");
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
}
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.CargaFamiliarBean;
import trismegistoplanilla.beans.PersonaBean;
import trismegistoplanilla.dao.CargaFamiliarDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class CargaFamiliarMysqlDAO implements CargaFamiliarDAO {
@Override
public JSONObject validarExistenciaNumeroDocumento(CargaFamiliarBean cargaFamiliar) {
System.out.println("CargaFamiliarSqlserverDAO: validarExistenciaNumeroDocumento");
JSONObject jsonValidarExistenciaNumeroDocumento = null;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
ResponseHelper response = new ResponseHelper();
int existeNumeroDocumentoFamiliar = 0;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select count(1) existeNumeroDocumentoFamiliar "
+ "from carga_familiar "
+ "where numero_documento = ? and estado_registro = 1";
ps = connection.prepareStatement(sql);
ps.setString(1, cargaFamiliar.getNumeroDocumento());
rs = ps.executeQuery();
rs.next();
existeNumeroDocumentoFamiliar = rs.getInt("existeNumeroDocumentoFamiliar");
if (existeNumeroDocumentoFamiliar > 0) {
response.setStatus(false);
response.setMessage("Error, el número de documento que acaba de ingresar, ya se encuentra registrado en el sistema.");
} else if (existeNumeroDocumentoFamiliar == 0) {
response.setStatus(true);
response.setMessage("El número de documento puede ser registrado.");
}
} 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();
}
}
jsonValidarExistenciaNumeroDocumento = new JSONObject(response);
return jsonValidarExistenciaNumeroDocumento;
}
@Override
public JSONObject obtenerCargaFamiliarPorPersona(PersonaBean persona) {
System.out.println("CargaFamiliarSqlserverDAO: obtenerCargaFamiliarPorPersona");
JSONObject jsonObjObtenerCargaFamiliarPorPersona = null;
JSONArray jsonArrayObtenerCargaFamiliarPorPersona = new JSONArray();
ResponseHelper response = new ResponseHelper();
PreparedStatement ps = null;
ResultSet rs = null;
Connection cnx = null;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "SELECT "
+ "cargafamiliar.apellido_paterno apellidoPaterno , "
+ "cargafamiliar.apellido_materno apellidoMaterno , "
+ "cargafamiliar.nombre nombre, "
+ "parentesco.nombre parentesco, "
+ "Format(cargafamiliar.fecha_nacimiento, 'dd/MM/yyyy') fechaNacimiento , "
+ "(cast(datediff(dd,cargafamiliar.fecha_nacimiento,getdate()) / 365.25 as int)) edad, "
+ "tipodocumento.descripcion_larga tipoDocumentoDescripcionLarga, "
+ "tipodocumento.descripcion_corta tipoDocumentoDescripcionCorta, "
+ "cargafamiliar.numero_documento numeroDocumento , "
+ "cargafamiliar.sexo sexo, "
+ "Isnull(cargafamiliar.telefono, '-') telefono "
+ "FROM carga_familiar cargafamiliar "
+ "INNER JOIN parentesco parentesco ON parentesco.codigo_parentesco = cargafamiliar.codigo_parentesco "
+ "INNER JOIN tipo_documento tipodocumento ON tipodocumento.codigo_tipo_documento = cargafamiliar.codigo_tipo_documento "
+ "WHERE cargafamiliar.codigo_persona = ?";
ps = cnx.prepareStatement(sql);
ps.setInt(1, persona.getCodigoPersona());
rs = ps.executeQuery();
while (rs.next()) {
CargaFamiliarBean cargaFamiliar = new CargaFamiliarBean();
cargaFamiliar.setApellidoPaterno(rs.getString("apellidoPaterno"));
cargaFamiliar.setApellidoMaterno(rs.getString("apellidoMaterno"));
cargaFamiliar.setNombre(rs.getString("nombre"));
cargaFamiliar.setNombreParentesco(rs.getString("parentesco"));
cargaFamiliar.setFechaNacimiento(rs.getString("fechaNacimiento"));
cargaFamiliar.setEdad(rs.getString("edad"));
cargaFamiliar.setNombreTipoDocumentoDescripcionLarga(rs.getString("tipoDocumentoDescripcionLarga"));
cargaFamiliar.setNombreTipoDocumentoDescripcionCorta(rs.getString("tipoDocumentoDescripcionCorta"));
cargaFamiliar.setNumeroDocumento(rs.getString("numeroDocumento"));
cargaFamiliar.setSexo(rs.getString("sexo"));
cargaFamiliar.setTelefono(rs.getString("telefono"));
JSONObject jsonObjCargaFamiliar = new JSONObject(cargaFamiliar);
jsonArrayObtenerCargaFamiliarPorPersona.put(jsonObjCargaFamiliar);
}
JSONObject jsonObjCargaFamiliar = new JSONObject();
jsonObjCargaFamiliar.put("cargafamiliar", jsonArrayObtenerCargaFamiliarPorPersona);
response.setStatus(true);
response.setMessage("Se ha listado la carga familiar correctamente");
response.setData(jsonObjCargaFamiliar);
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerCargaFamiliarPorPersona = new JSONObject(response);
return jsonObjObtenerCargaFamiliarPorPersona;
}
}
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.AreaBean;
import trismegistoplanilla.beans.CargoBean;
import trismegistoplanilla.dao.CargoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class CargoMysqlDAO implements CargoDAO {
@Override
public JSONObject listarCargo(AreaBean a) {
System.out.println("CargoSqlserverDAO: listarCargo");
JSONObject JOListarCargo = null;
JSONArray JArrayCargo = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "area_cargo.codigo_cargo codigoCargo, "
+ "cargo.nombre "
+ "from area_cargo "
+ "inner join dbo.cargo ON dbo.cargo.codigo_cargo = dbo.area_cargo.codigo_cargo "
+ "where area_cargo.estado_registro = 1 and area_cargo.codigo_area = ?";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, a.getCodigoArea());
rs = ps.executeQuery();
while (rs.next()) {
CargoBean c = new CargoBean();
c.setCodigoCargo(rs.getInt("codigoCargo"));
c.setNombre(rs.getString("nombre"));
JSONObject objCargo = new JSONObject(c);
JArrayCargo.put(objCargo);
}
JSONObject objCargo = new JSONObject();
objCargo.put("cargos", JArrayCargo);
response.setStatus(true);
response.setMessage("Los cargos se listaron correctamente");
response.setData(objCargo);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOListarCargo = new JSONObject(response);
return JOListarCargo;
}
@Override
public JSONObject validarExistenciaCargo(AreaBean a, CargoBean c) {
System.out.println("CargoSqlserverDAO: validarExistenciaCargo");
JSONObject JOValidarExistenciaCargo = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "count(1) existeCargo "
+ "from area_cargo "
+ "where area_cargo.estado_registro = 1 and area_cargo.codigo_area = ? and area_cargo.codigo_cargo = ?";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, a.getCodigoArea());
ps.setInt(2, c.getCodigoCargo());
rs = ps.executeQuery();
rs.next();
int existeCargo = 0;
existeCargo = rs.getInt("existeCargo");
if (existeCargo > 0) {
response.setStatus(true);
response.setMessage("El cargo seleccionada existe");
} else {
response.setStatus(false);
response.setMessage("Error! El cargo 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOValidarExistenciaCargo = new JSONObject(response);
return JOValidarExistenciaCargo;
}
@Override
public JSONObject registrar(JSONObject datos) {
System.out.println("CargoSqlserverDAO: registrar");
JSONObject jObject = null;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "insert into cargo (nombre, estado_registro) values (?, 1)";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
cnx.setAutoCommit(false);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("cargo"));
resultado = ps.executeUpdate();
if (resultado == 1) {
cnx.commit();
response.setStatus(true);
response.setMessage("Se registró el cargo correctamente!");
} else {
cnx.rollback();
response.setStatus(false);
response.setMessage("No se pudo registrar el cargo.");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
@Override
public JSONObject editar(JSONObject datos) {
System.out.println("CargoSqlserverDAO: editar");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
@Override
public JSONObject estado(JSONObject datos) {
System.out.println("CargoSqlserverDAO: estado");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
@Override
public JSONObject validarNombreAdd(JSONObject datos) {
System.out.println("CargoSqlserverDAO: validarNombreAdd");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select count(1) cantidad "
+ "FROM cargo "
+ "where cargo.nombre = ?";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("cargo"));
rs = ps.executeQuery();
if (rs.next()) {
resultado = rs.getInt("cantidad");
if (resultado == 1) {
response.setStatus(false);
response.setMessage("Ya existe un cargo con ese nombre");
} else {
response.setStatus(true);
response.setMessage("Puede proceder a registrar el cargo");
}
} else {
response.setStatus(false);
response.setMessage("No se pudo encontrar el cargo");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
@Override
public JSONObject validarNombreEdit(JSONObject datos) {
System.out.println("CargoSqlserverDAO: validarNombreEdit");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select count(1) "
+ "FROM area "
+ "where cargo.nombre = ? "
+ "and cargo.codigo_cargo not in (?)";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("cargo"));
ps.setInt(2, datos.getInt("codigoCargo"));
rs = ps.executeQuery();
if (rs.next()) {
resultado = rs.getInt("cantidad");
if (resultado == 1) {
response.setStatus(false);
response.setMessage("Ya existe un cargo con ese nombre");
} else {
response.setStatus(true);
response.setMessage("Puede proceder a actualizar el cargo");
}
} else {
response.setStatus(false);
response.setMessage("No se pudo encontrar el cargo");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
}
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) {
System.out.println("CarreraProfesionalSqlserverDAO: listarCarreraProfesional");
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 {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
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) {
System.out.println("CarreraProfesionalSqlserverDAO: validarExistenciaCarreraProfesional");
JSONObject jsonValidarExistenciaCarreraProfesional = null;
ResponseHelper response = new ResponseHelper();
int existeCarreraProfesional = 0;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
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;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.dao.ConfiguracionFichaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class ConfiguracionFichaMysqlDAO implements ConfiguracionFichaDAO {
@Override
public JSONObject getDefaultMail() {
System.out.println("ConfiguracionFichaSqlserverDAO: getDefaultMail");
JSONObject JOmail = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "correo "
+ "from configuracion_ficha "
+ "where estado = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
rs = ps.executeQuery();
rs.next();
JSONObject obj = new JSONObject();
obj.put("mail", rs.getString("correo"));
response.setData(obj);
response.setStatus(true);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOmail = new JSONObject(response);
return JOmail;
}
}
package trismegistoplanilla.mysqldao;
import java.io.UnsupportedEncodingException;
import java.util.Properties;
import javax.mail.Authenticator;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import trismegistoplanilla.beans.Correo;
import trismegistoplanilla.dao.CorreoDAO;
public class CorreoMysqlDAO implements CorreoDAO {
@Override
public boolean enviarCorreo(Correo c) {
System.out.println("CorreoSqlserverDAO: enviarCorreo");
boolean envio;
try {
Properties p = new Properties();
p.put("mail.smtp.host", "smtp.gmail.com");
p.setProperty("mail.smtp.starttls.enable", "true");
p.setProperty("mail.smtp.port", "587");
p.setProperty("mail.smtp.user", "tplanilla@gmail.com");
p.setProperty("mail.smtp.auth", "true");
Session session = Session.getInstance(p, new Authenticator() {
@Override
protected PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication("tplanilla@gmail.com", "aylffncgufqnockh");
}
});
Message message = new MimeMessage(session);
message.setFrom(new InternetAddress("tplanilla@gmail.com", "TRISMEGISTO - PLANILLA"));
message.setRecipients(Message.RecipientType.TO, InternetAddress.parse(c.getDestino()));
message.setSubject(c.getAsunto());
message.setContent(c.getMensaje(), "text/html; chartset=utf-8");
Transport.send(message, message.getAllRecipients());
envio = true;
} catch (UnsupportedEncodingException | MessagingException e) {
e.printStackTrace();
envio = false;
}
return envio;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.AreaCargoTipoPagoBean;
import trismegistoplanilla.dao.EscalafonDAO;
import static trismegistoplanilla.utilities.CurrencyFormat.getCustomCurrency;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class EscalafonMysqlDAO implements EscalafonDAO {
@Override
public JSONObject obtenerEscalafonAreaCargoTipoPago(AreaCargoTipoPagoBean actp) {
System.out.println("EscalafonSqlserverDAO: obtenerEscalafonAreaCargoTipoPago");
JSONObject jsonObtenerEscalafonAreaCargo = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "sueldo "
+ "from escalafon "
+ "where codigo_area_cargo_tipo_pago = ? and estado_registro = 1";
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sueldo = "";
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setInt(1, actp.getCodigoAreaCargoTipoPago());
rs = ps.executeQuery();
if (rs.next()) {
sueldo = getCustomCurrency(rs.getDouble("sueldo"));
response.setStatus(true);
JSONObject jsonObjSueldo = new JSONObject();
jsonObjSueldo.put("sueldo", sueldo);
response.setData(jsonObjSueldo);
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObtenerEscalafonAreaCargo = new JSONObject(response);
return jsonObtenerEscalafonAreaCargo;
}
}
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.EstadoCivilBean;
import trismegistoplanilla.dao.EstadoCivilDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class EstadoCivilMysqlDAO implements EstadoCivilDAO {
@Override
public JSONObject listarEstadoCivil() {
System.out.println("EstadoCivilSqlserverDAO: listarEstadoCivil");
JSONObject jsonListarEstadoCivil = null;
JSONArray jsonArrayListarEstadoCivil = new JSONArray();
PreparedStatement ps = null;
ResultSet rs = null;
Connection connection = null;
ResponseHelper response = new ResponseHelper();
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "codigo_estado_civil estadoCivil, "
+ "nombre nombre, "
+ "estado_registro estadoRegistro "
+ "FROM estado_civil "
+ "where estado_registro = 1";
ps = connection.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
EstadoCivilBean estadoCivil = new EstadoCivilBean();
estadoCivil.setCodigoEstadoCivil(rs.getInt("estadoCivil"));
estadoCivil.setNombre(rs.getString("nombre"));
estadoCivil.setEstado_registro(rs.getInt("estadoRegistro"));
JSONObject jsonObjEstadoCivil = new JSONObject(estadoCivil);
jsonArrayListarEstadoCivil.put(jsonObjEstadoCivil);
}
JSONObject jsonObjEstadoCivil = new JSONObject();
jsonObjEstadoCivil.put("EstadosCiviles", jsonArrayListarEstadoCivil);
response.setStatus(true);
response.setMessage("Los estados civiles se han listado correctamente");
response.setData(jsonObjEstadoCivil);
} 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();
}
}
jsonListarEstadoCivil = new JSONObject(response);
return jsonListarEstadoCivil;
}
@Override
public JSONObject validarExistenciaEstadoCivil(EstadoCivilBean estadoCivil) {
System.out.println("EstadoCivilSqlserverDAO: validarExistenciaEstadoCivil");
JSONObject jsonValidarExistenciaEstadoCivil = null;
ResponseHelper response = new ResponseHelper();
int existeEstadoCivil = 0;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "count(1) as existeEstadoCivil "
+ "from estado_civil "
+ "where codigo_estado_civil = ? and estado_registro = 1";
ps = connection.prepareStatement(sql);
ps.setInt(1, estadoCivil.getCodigoEstadoCivil());
rs = ps.executeQuery();
rs.next();
existeEstadoCivil = rs.getInt("existeEstadoCivil");
if (existeEstadoCivil > 0) {
response.setStatus(true);
response.setMessage("El estado civil seleccionado existe.");
} else {
response.setStatus(false);
response.setMessage("El estado civil seleccionado 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();
}
}
jsonValidarExistenciaEstadoCivil = new JSONObject(response);
return jsonValidarExistenciaEstadoCivil;
}
}
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.EstadoEstudioBean;
import trismegistoplanilla.dao.EstadoEstudioDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class EstadoEstudioMysqlDAO implements EstadoEstudioDAO {
@Override
public JSONObject validarExistenciaEstadoEstudio(EstadoEstudioBean estadoEstudio) {
System.out.println("EstadoEstudioSqlserverDAO: validarExistenciaEstadoEstudio");
JSONObject jsonValidarExistenciaEstadoEstudio = null;
ResponseHelper response = new ResponseHelper();
int existeEstadoEstudio = 0;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "count (1) existeEstadoEstudio "
+ "from nivel_estado "
+ "inner join dbo.nivel_estudio ON dbo.nivel_estudio.codigo_nivel_estudio = dbo.nivel_estado.codigo_nivel_estudio "
+ "inner join dbo.estado_estudio ON dbo.estado_estudio.codigo_estado_estudio = dbo.nivel_estado.codigo_estado_estudio "
+ "where nivel_estudio.estado_registro = 1 "
+ "and nivel_estado.codigo_nivel_estudio = ? "
+ "and nivel_estado.codigo_estado_estudio = ?";
ps = connection.prepareStatement(sql);
ps.setInt(1, estadoEstudio.getCodigoNivelEstudio());
ps.setInt(2, estadoEstudio.getCodigoEstadoEstudio());
rs = ps.executeQuery();
rs.next();
existeEstadoEstudio = rs.getInt("existeEstadoEstudio");
if (existeEstadoEstudio > 0) {
response.setStatus(true);
response.setMessage("El estado estudio seleccionado existe.");
} else {
response.setStatus(false);
response.setMessage("El estado estudio seleccionado 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();
}
}
jsonValidarExistenciaEstadoEstudio = new JSONObject(response);
return jsonValidarExistenciaEstadoEstudio;
}
@Override
public JSONObject listarEstadoEstudio(EstadoEstudioBean estadoEstudio) {
System.out.println("EstadoEstudioSqlserverDAO: listarEstadoEstudio");
JSONObject jsonListarEstadoEstudio = null;
JSONArray jsonArrayListarEstadoEstudio = new JSONArray();
ResponseHelper response = new ResponseHelper();
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "estado_estudio.codigo_estado_estudio codigoEstadoEstudio, "
+ "estado_estudio.nombre nombreEstadoEstudio "
+ "from nivel_estado "
+ "inner join dbo.estado_estudio ON dbo.estado_estudio.codigo_estado_estudio = dbo.nivel_estado.codigo_estado_estudio "
+ "where estado_estudio.estado_registro = 1 and nivel_estado.codigo_nivel_estudio = ?";
ps = connection.prepareStatement(sql);
ps.setInt(1, estadoEstudio.getCodigoNivelEstudio());
rs = ps.executeQuery();
while (rs.next()) {
estadoEstudio.setCodigoEstadoEstudio(rs.getInt("codigoEstadoEstudio"));
estadoEstudio.setNombre(rs.getString("nombreEstadoEstudio"));
JSONObject jsonObjEstadoEstudio = new JSONObject(estadoEstudio);
jsonArrayListarEstadoEstudio.put(jsonObjEstadoEstudio);
}
JSONObject jsonObjEstadoEstudio = new JSONObject();
jsonObjEstadoEstudio.put("estadoestudio", jsonArrayListarEstadoEstudio);
response.setStatus(true);
response.setMessage("Los estados de estudio se han listado correctamente");
response.setData(jsonObjEstadoEstudio);
} 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();
}
}
jsonListarEstadoEstudio = new JSONObject(response);
return jsonListarEstadoEstudio;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.EstadoFichaBean;
import trismegistoplanilla.dao.EstadoFichaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class EstadoFichaMysqlDAO implements EstadoFichaDAO {
@Override
public JSONObject obtenerCodigoEstadoFicha(EstadoFichaBean ef) {
System.out.println("EstadoFichaSqlserverDAO: obtenerCodigoEstadoFicha");
JSONObject JOObtenerCodigoEstadoFicha = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "codigo_estado_ficha codigoEstadoFicha "
+ "from estado_ficha "
+ "where codigo_ficha = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, ef.getCodigoFicha());
rs = ps.executeQuery();
rs.next();
int codigoEstadoFicha = rs.getInt("codigoEstadoFicha");
if (codigoEstadoFicha > 0) {
JSONObject objEstadoFicha = new JSONObject();
objEstadoFicha.put("getResultedKey", codigoEstadoFicha);
response.setStatus(true);
response.setMessage("Se encontró el codigo de estado de ficha");
response.setData(objEstadoFicha);
} else {
response.setStatus(false);
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOObtenerCodigoEstadoFicha = new JSONObject(response);
return JOObtenerCodigoEstadoFicha;
}
@Override
public JSONObject desactivarEstadoFicha(EstadoFichaBean ef) {
System.out.println("EstadoFichaSqlserverDAO: desactivarEstadoFicha");
JSONObject JODesactivarEstadoFicha = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "update estado_ficha "
+ "set estado_registro = 0 "
+ "where codigo_estado_ficha = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
conexion.setAutoCommit(false);
ps = conexion.prepareStatement(sql);
ps.setInt(1, ef.getCodigoEstadoFicha());
int resultadoDesactivar = ps.executeUpdate();
if (resultadoDesactivar > 0) {
response.setStatus(true);
response.setMessage("El estado de ficha [" + ef.getCodigoEstadoFicha() + "] se ha desactivado");
conexion.commit();
} else {
response.setStatus(false);
response.setMessage("Error!, no se ha podido desactivar el estado de ficha");
conexion.rollback();
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JODesactivarEstadoFicha = new JSONObject(response);
return JODesactivarEstadoFicha;
}
@Override
public JSONObject registrarEstadoFicha(EstadoFichaBean ef) {
System.out.println("EstadoFichaSqlserverDAO: registrarEstadoFicha");
JSONObject JORegistrarEstadoFicha = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "insert into estado_ficha ( "
+ " codigo_ficha "
+ " ,codigo_tipo_estado_ficha "
+ " ,fecha_registro "
+ " ,codigo_usuario "
+ " ,estado_registro "
+ ") values ( "
+ " ? "
+ " ,? "
+ " ,getdate() "
+ " ,? "
+ " ,1 "
+ ")";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
conexion.setAutoCommit(false);
ps = conexion.prepareStatement(sql);
ps.setInt(1, ef.getCodigoFicha());
ps.setInt(2, ef.getCodigoTipoEstadoFicha());
ps.setInt(3, ef.getCodigoUsuario());
int resultadoRegistro = ps.executeUpdate();
if (resultadoRegistro > 0) {
response.setStatus(true);
response.setMessage("Enhorabuena!, se ha registrado un nuevo estado de ficha");
conexion.commit();
} else {
response.setStatus(false);
response.setMessage("Error!, no se ha podido regsitrar un nuevo estado de ficha");
conexion.rollback();
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JORegistrarEstadoFicha = new JSONObject(response);
return JORegistrarEstadoFicha;
}
}
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.ExpedienteBean;
import trismegistoplanilla.beans.PersonaBean;
import trismegistoplanilla.dao.ExpedienteDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class ExpedienteMysqlDAO implements ExpedienteDAO {
@Override
public JSONObject listarTipoExpedientes() {
System.out.println("ExpedienteSqlserverDAO: listarTipoExpedientes");
JSONObject jsonObjListarTipoExpediente = null;
JSONArray jsonArrayListarTipoExpediente = new JSONArray();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
ResponseHelper response = new ResponseHelper();
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "codigo_tipo_expediente codigoTipoExpediente, "
+ "nombre nombreExpediente "
+ "FROM tipo_expediente "
+ "where tipo_expediente.estado_registro = 1";
ps = cnx.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
ExpedienteBean expediente = new ExpedienteBean();
expediente.setCodigoTipoExpediente(rs.getInt("codigoTipoExpediente"));
expediente.setNombreExpediente(rs.getString("nombreExpediente"));
JSONObject jsonObjExpediente = new JSONObject(expediente);
jsonArrayListarTipoExpediente.put(jsonObjExpediente);
}
JSONObject jsonObjExpediente = new JSONObject();
jsonObjExpediente.put("expediente", jsonArrayListarTipoExpediente);
response.setStatus(true);
response.setMessage("Se ha listado los tipos de expediente correctamente.");
response.setData(jsonObjExpediente);
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjListarTipoExpediente = new JSONObject(response);
return jsonObjListarTipoExpediente;
}
@Override
public JSONObject obtenerExpedientesPorPersona(PersonaBean persona) {
System.out.println("ExpedienteSqlserverDAO: obtenerExpedientesPorPersona");
JSONObject jsonObjObtenerExpedientesPorPersona = null;
JSONArray jsonArrayObtenerExpedientesPorPersona = new JSONArray();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
ResponseHelper response = new ResponseHelper();
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "tipo_expediente.nombre nombreExpediente "
+ "FROM expediente "
+ "inner join tipo_expediente "
+ "ON tipo_expediente.codigo_tipo_expediente = expediente.codigo_tipo_expediente "
+ "where expediente.estado_registro = 1 "
+ "and expediente.codigo_persona = ? ";
ps = cnx.prepareStatement(sql);
ps.setInt(1, persona.getCodigoPersona());
rs = ps.executeQuery();
while (rs.next()) {
ExpedienteBean expediente = new ExpedienteBean();
expediente.setNombreExpediente(rs.getString("nombreExpediente"));
JSONObject jsonObjExpediente = new JSONObject(expediente);
jsonArrayObtenerExpedientesPorPersona.put(jsonObjExpediente);
}
JSONObject jsonObjExpediente = new JSONObject();
jsonObjExpediente.put("expediente", jsonArrayObtenerExpedientesPorPersona);
response.setStatus(true);
response.setMessage("Se obtuvo los expedientes correctamente.");
response.setData(jsonObjExpediente);
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerExpedientesPorPersona = new JSONObject(response);
return jsonObjObtenerExpedientesPorPersona;
}
}
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.ExperienciaLaboralBean;
import trismegistoplanilla.beans.PersonaBean;
import trismegistoplanilla.dao.ExperienciaLaboralDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class ExperienciaLaboralMysqlDAO implements ExperienciaLaboralDAO {
@Override
public JSONObject obtenerExperienciaLaboralPorPersona(PersonaBean persona) {
System.out.println("ExperienciaLaboralSqlserverDAO: obtenerExperienciaLaboralPorPersona");
JSONObject jsonObjObtenerExperienciaLaboralPorPersona = null;
JSONArray jsonArrayObtenerExperienciaLaboralPorPersona = new JSONArray();
ResponseHelper response = new ResponseHelper();
PreparedStatement ps = null;
ResultSet rs = null;
Connection cnx = null;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "SELECT "
+ "experiencialaboral.nombre_empresa nombreEmpresa, "
+ "experiencialaboral.nombre_cargo nombreCargo, "
+ "Format(experiencialaboral.fecha_inicio, 'dd/MM/yyyy') fechaInicio, "
+ "Format(experiencialaboral.fecha_fin, 'dd/MM/yyyy') fechaFin, "
+ "Isnull(experiencialaboral.telefono, '-') telefono "
+ "FROM experiencia_laboral experiencialaboral "
+ "WHERE experiencialaboral.codigo_persona = ?";
ps = cnx.prepareStatement(sql);
ps.setInt(1, persona.getCodigoPersona());
rs = ps.executeQuery();
while (rs.next()) {
ExperienciaLaboralBean experienciaLaboral = new ExperienciaLaboralBean();
experienciaLaboral.setNombreEmpresa(rs.getString("nombreEmpresa"));
experienciaLaboral.setNombreCargo(rs.getString("nombreCargo"));
experienciaLaboral.setFechaInicio(rs.getString("fechaInicio"));
experienciaLaboral.setFechaFin(rs.getString("fechaFin"));
experienciaLaboral.setTelefono(rs.getString("telefono"));
JSONObject jsonObjExperienciaLaboral = new JSONObject(experienciaLaboral);
jsonArrayObtenerExperienciaLaboralPorPersona.put(jsonObjExperienciaLaboral);
}
JSONObject jsonObjExperienciaLaboral = new JSONObject();
jsonObjExperienciaLaboral.put("experiencialaboral", jsonArrayObtenerExperienciaLaboralPorPersona);
response.setStatus(true);
response.setMessage("Se ha listado la experiencia laboral correctamente");
response.setData(jsonObjExperienciaLaboral);
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerExperienciaLaboralPorPersona = new JSONObject(response);
return jsonObjObtenerExperienciaLaboralPorPersona;
}
}
This source diff could not be displayed because it is too large. You can view the blob instead.
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.FondoPensionBean;
import trismegistoplanilla.dao.FondoPensionDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class FondoPensionMysqlDAO implements FondoPensionDAO {
@Override
public JSONObject listarFondoPension() {
System.out.println("FondoPensionSqlserverDAO: listarFondoPension");
JSONObject jsonListarFondoPension = null;
JSONArray jsonArrayListarFondoPension = new JSONArray();
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
ResponseHelper response = new ResponseHelper();
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "codigo_fondo_pension codigoFondoPension, "
+ "descripcion_corta descripcionCorta, "
+ "descripcion_larga descripcionLarga, "
+ "estado_registro estadoRegistro "
+ "FROM fondo_pension "
+ "where estado_registro = 1";
ps = connection.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
FondoPensionBean fondoPension = new FondoPensionBean();
fondoPension.setCodigoFondoPension(rs.getInt("codigoFondoPension"));
fondoPension.setDescripcionCorta(rs.getString("descripcionCorta"));
fondoPension.setDescripcionLarga(rs.getString("descripcionLarga").trim());
JSONObject jsonObjFondoPension = new JSONObject(fondoPension);
jsonArrayListarFondoPension.put(jsonObjFondoPension);
}
JSONObject jsonObjFondoPension = new JSONObject();
jsonObjFondoPension.put("fondopension", jsonArrayListarFondoPension);
response.setStatus(true);
response.setMessage("Los fondos de pensiones se han listado correctamente");
response.setData(jsonObjFondoPension);
} 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();
}
}
jsonListarFondoPension = new JSONObject(response);
return jsonListarFondoPension;
}
@Override
public JSONObject validarExistenciaFondoPension(FondoPensionBean fondoPension) {
System.out.println("FondoPensionSqlserverDAO: validarExistenciaFondoPension");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
}
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.FormacionAcademicaBean;
import trismegistoplanilla.beans.PersonaBean;
import trismegistoplanilla.dao.FormacionAcademicaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class FormacionAcademicaMysqlDAO implements FormacionAcademicaDAO {
@Override
public JSONObject obtenerFormacionAcademicaPorPersona(PersonaBean persona) {
System.out.println("FormacionAcademicaSqlserverDAO: obtenerFormacionAcademicaPorPersona");
JSONObject jsonObjObtenerFormacionAcademicaPorPersona = null;
JSONArray jsonArrayObtenerFormacionAcademicaPorPersona = new JSONArray();
ResponseHelper response = new ResponseHelper();
PreparedStatement ps = null;
ResultSet rs = null;
Connection cnx = null;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "SELECT "
+ "formacionacademica.nombre_centro_estudio centroEstudios, "
+ "nivelestudio.nombre nivelEstudio, "
+ "estadoestudio.nombre estadoEstudio, "
+ "Format(formacionacademica.fecha_inicio, 'dd/MM/yyyy') fechaInicio, "
+ "isnull(Format(formacionacademica.fecha_fin, 'dd/MM/yyyy'),'-') fechaFin, "
+ "Isnull(formacionacademica.documento_adjunto, 'NO TIENE DOCUMENTO ADJUNTO') documentoAdjunto,"
+ "IsNull(formacionacademica.carrera_profesional,'-') carreraProfesional, "
+ "formacionacademica.sector_institucion sectorInstitucion, "
+ "Isnull(formacionacademica.numero_colegiatura, '-') numeroColegiatura, "
+ "Isnull(formacionacademica.observacion, '-') observacion "
+ "FROM formacion_academica formacionacademica "
+ "INNER JOIN nivel_estado nivelestado ON nivelestado.codigo_nivel_estado = formacionacademica.codigo_nivel_estado "
+ "INNER JOIN estado_estudio estadoestudio ON estadoestudio.codigo_estado_estudio = nivelestado.codigo_estado_estudio "
+ "INNER JOIN nivel_estudio nivelestudio ON nivelestudio.codigo_nivel_estudio = nivelestado.codigo_nivel_estudio "
+ "where formacionacademica.codigo_persona = ?";
ps = cnx.prepareStatement(sql);
ps.setInt(1, persona.getCodigoPersona());
rs = ps.executeQuery();
while (rs.next()) {
FormacionAcademicaBean formacionAcademica = new FormacionAcademicaBean();
formacionAcademica.setNombreCentroEstudios(rs.getString("centroEstudios"));
formacionAcademica.setNivelEstudio(rs.getString("nivelEstudio"));
formacionAcademica.setEstadoEstudio(rs.getString("estadoEstudio"));
formacionAcademica.setFechaInicio(rs.getString("fechaInicio"));
formacionAcademica.setFechaFin(rs.getString("fechaFin"));
formacionAcademica.setDocumentoAdjunto(rs.getString("documentoAdjunto"));
formacionAcademica.setNombreCarreraProfesional(rs.getString("carreraProfesional"));
formacionAcademica.setSectorInstitucion(rs.getString("sectorInstitucion"));
formacionAcademica.setNumeroColegiatura(rs.getString("numeroColegiatura"));
formacionAcademica.setObservacion(rs.getString("observacion"));
JSONObject jsonObjFormacionAcademica = new JSONObject(formacionAcademica);
jsonArrayObtenerFormacionAcademicaPorPersona.put(jsonObjFormacionAcademica);
}
JSONObject jsonObjFormacionAcademica = new JSONObject();
jsonObjFormacionAcademica.put("formacionacademica", jsonArrayObtenerFormacionAcademicaPorPersona);
response.setStatus(true);
response.setMessage("Se ha listado la formacion academica correctamente");
response.setData(jsonObjFormacionAcademica);
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerFormacionAcademicaPorPersona = new JSONObject(response);
return jsonObjObtenerFormacionAcademicaPorPersona;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import trismegistoplanilla.dao.AreaCargoDAO;
import trismegistoplanilla.dao.AreaCargoTipoPagoDAO;
import trismegistoplanilla.dao.AreaDAO;
import trismegistoplanilla.dao.CargaFamiliarDAO;
import trismegistoplanilla.dao.CargoDAO;
import trismegistoplanilla.dao.CarreraProfesionalDAO;
import trismegistoplanilla.dao.ConfiguracionFichaDAO;
import trismegistoplanilla.dao.DAOFactory;
import trismegistoplanilla.dao.DetalleLoteFichaDocenteDAO;
import trismegistoplanilla.dao.EscalafonDAO;
import trismegistoplanilla.dao.EstadoCivilDAO;
import trismegistoplanilla.dao.EstadoEstudioDAO;
import trismegistoplanilla.dao.EstadoFichaDAO;
import trismegistoplanilla.dao.ExpedienteDAO;
import trismegistoplanilla.dao.ExperienciaLaboralDAO;
import trismegistoplanilla.dao.FichaDAO;
import trismegistoplanilla.dao.FichaLaboralDAO;
import trismegistoplanilla.dao.FondoPensionDAO;
import trismegistoplanilla.dao.FormacionAcademicaDAO;
import trismegistoplanilla.dao.LoteFichaDAO;
import trismegistoplanilla.dao.NacionalidadDAO;
import trismegistoplanilla.dao.NivelEstadoDAO;
import trismegistoplanilla.dao.NivelEstudioDAO;
import trismegistoplanilla.dao.ParentescoDAO;
import trismegistoplanilla.dao.PersonaDAO;
import trismegistoplanilla.dao.ReportePersonalDAO;
import trismegistoplanilla.dao.SedeAreaDAO;
import trismegistoplanilla.dao.SedeDAO;
import trismegistoplanilla.dao.TipoDocumentoDAO;
import trismegistoplanilla.dao.TipoEstadoFichaDAO;
import trismegistoplanilla.dao.TipoExpedienteDAO;
import trismegistoplanilla.dao.TipoPagoDAO;
import trismegistoplanilla.dao.TokenFichaDAO;
import trismegistoplanilla.dao.TrabajadorResponsableDAO;
import trismegistoplanilla.dao.UbigeoDAO;
import trismegistoplanilla.dao.VacanteDAO;
public class MysqlDAOFactory extends DAOFactory {
static {
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
} catch (ClassNotFoundException ex) {
ex.printStackTrace();
}
}
public static Connection obtenerConexion(String base) {
Connection conexion = null;
String user;
String pwd;
String url;
if (base.equalsIgnoreCase("planillabd")) {
user = "sa";
url = "jdbc:sqlserver://172.16.0.5:1433;databaseName=planillabd";
pwd = "Saco1357$";
try {
conexion = DriverManager.getConnection(url, user, pwd);
} catch (SQLException e) {
e.printStackTrace();
}
}
return conexion;
}
@Override
public TipoDocumentoDAO getTipoDocumentoDAO() {
return new TipoDocumentoMysqlDAO();
}
@Override
public PersonaDAO getPersonaDAO() {
return new PersonaMysqlDAO();
}
@Override
public FichaDAO getFichaDAO() {
return new FichaMysqlDAO();
}
@Override
public TokenFichaDAO getTokenFichaDAO() {
return new TokenFichaMysqlDAO();
}
@Override
public EstadoCivilDAO getEstadoCivilDAO() {
return new EstadoCivilMysqlDAO();
}
@Override
public NacionalidadDAO getNacionalidadDAO() {
return new NacionalidadMysqlDAO();
}
@Override
public UbigeoDAO getUbigeoDAO() {
return new UbigeoMysqlDAO();
}
@Override
public ParentescoDAO getParentescoDAO() {
return new ParentescoMysqlDAO();
}
@Override
public CargaFamiliarDAO getCargaFamiliarDAO() {
return new CargaFamiliarMysqlDAO();
}
@Override
public CarreraProfesionalDAO getCarreraProfesionalDAO() {
return new CarreraProfesionalMysqlDAO();
}
@Override
public NivelEstudioDAO getNivelEstudioDAO() {
return new NivelEstudioMysqlDAO();
}
@Override
public EstadoEstudioDAO getEstadoEstudioDAO() {
return new EstadoEstudioMysqlDAO();
}
@Override
public NivelEstadoDAO getNivelEstadoDAO() {
return new NivelEstadoMysqlDAO();
}
@Override
public FondoPensionDAO getFondoPensionDAO() {
return new FondoPensionMysqlDAO();
}
@Override
public ExperienciaLaboralDAO getExperienciaLaboralDAO() {
return new ExperienciaLaboralMysqlDAO();
}
@Override
public FormacionAcademicaDAO getFormacionAcademicaDAO() {
return new FormacionAcademicaMysqlDAO();
}
@Override
public SedeDAO getSedeDAO() {
return new SedeMysqlDAO();
}
@Override
public AreaDAO getAreaDAO() {
return new AreaMysqlDAO();
}
@Override
public SedeAreaDAO getSedeAreaDAO() {
return new SedeAreaMysqlDAO();
}
@Override
public TrabajadorResponsableDAO getTrabajadorResponsableDAO() {
return new TrabajadorResponsableMysqlDAO();
}
@Override
public CargoDAO getCargoDAO() {
return new CargoMysqlDAO();
}
@Override
public EscalafonDAO getEscalafonDAO() {
return new EscalafonMysqlDAO();
}
@Override
public EstadoFichaDAO getEstadoFichaDAO() {
return new EstadoFichaMysqlDAO();
}
@Override
public FichaLaboralDAO getFichaLaboralDAO() {
return new FichaLaboralMysqlDAO();
}
@Override
public AreaCargoDAO getAreaCargoDAO() {
return new AreaCargoMysqlDAO();
}
@Override
public TipoPagoDAO getTipoPagoDAO() {
return new TipoPagoMysqlDAO();
}
@Override
public AreaCargoTipoPagoDAO getAreaCargoTipoPagoDAO() {
return new AreaCargoTipoPagoMysqlDAO();
}
@Override
public LoteFichaDAO getLoteFichaDAO() {
return new LoteFichaMysqlDAO();
}
@Override
public TipoEstadoFichaDAO getTipoEstadoFichaDAO() {
return new TipoEstadoFichaMysqlDAO();
}
@Override
public DetalleLoteFichaDocenteDAO getDetalleLoteFichaDocenteDAO() {
return new DetalleLoteFichaDocenteMysqlDAO();
}
@Override
public ExpedienteDAO getExpedienteDAO() {
return new ExpedienteMysqlDAO();
}
@Override
public TipoExpedienteDAO getTipoExpedienteDAO() {
return new TipoExpedienteMysqlDAO();
}
@Override
public ConfiguracionFichaDAO getConfiguracionFichaDAO() {
return new ConfiguracionFichaMysqlDAO();
}
@Override
public ReportePersonalDAO getReportePersonalDAO() {
return new ReportePersonalMysqlDAO();
}
@Override
public VacanteDAO getVacanteDAO() {
return new VacanteMysqlDAO();
}
}
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.NacionalidadBean;
import trismegistoplanilla.dao.NacionalidadDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class NacionalidadMysqlDAO implements NacionalidadDAO {
@Override
public JSONObject listarNacionalidad() {
System.out.println("NacionalidadSqlserverDAO: listarNacionalidad");
JSONObject jsonListarNacionalidad = null;
JSONArray jsonArrayListarNacionalidad = new JSONArray();
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
ResponseHelper response = new ResponseHelper();
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select codigo_nacionalidad codigoNacionalidad, "
+ "pais pais, "
+ "gentilicio gentilicio, "
+ "iso iso, "
+ "estado_registro estadoRegistro "
+ "FROM nacionalidad where estado_registro = 1";
ps = connection.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
NacionalidadBean nacionalidad = new NacionalidadBean();
nacionalidad.setCodigoNacionalidad(rs.getInt("codigoNacionalidad"));
nacionalidad.setPais(rs.getString("pais"));
nacionalidad.setGentilicio(rs.getString("gentilicio"));
nacionalidad.setIso(rs.getString("iso"));
nacionalidad.setEstadoRegistro(rs.getInt("estadoRegistro"));
JSONObject jsonObjListarNacionalidad = new JSONObject(nacionalidad);
jsonArrayListarNacionalidad.put(jsonObjListarNacionalidad);
}
JSONObject jsonObjListarNacionalidad = new JSONObject();
jsonObjListarNacionalidad.put("Nacionalidades", jsonArrayListarNacionalidad);
response.setStatus(true);
response.setMessage("Las nacionalidades se han listado correctamente");
response.setData(jsonObjListarNacionalidad);
} 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();
}
}
jsonListarNacionalidad = new JSONObject(response);
return jsonListarNacionalidad;
}
@Override
public JSONObject validarExistenciaNacionalidad(NacionalidadBean nacionalidad) {
System.out.println("NacionalidadSqlserverDAO: validarExistenciaNacionalidad");
JSONObject jsonvalidadExistenciaNacionalidad = null;
ResponseHelper response = new ResponseHelper();
int existeEstadoCivil = 0;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "count(1) as existeNacionalidad "
+ "from nacionalidad "
+ "where codigo_nacionalidad = ? and estado_registro = 1";
ps = connection.prepareStatement(sql);
ps.setInt(1, nacionalidad.getCodigoNacionalidad());
rs = ps.executeQuery();
rs.next();
existeEstadoCivil = rs.getInt("existeNacionalidad");
if (existeEstadoCivil > 0) {
response.setStatus(true);
response.setMessage("La nacionalidad seleccionada existe.");
} else {
response.setStatus(false);
response.setMessage("La nacionalidad 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();
}
}
jsonvalidadExistenciaNacionalidad = new JSONObject(response);
return jsonvalidadExistenciaNacionalidad;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.NivelEstadoBean;
import trismegistoplanilla.dao.NivelEstadoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class NivelEstadoMysqlDAO implements NivelEstadoDAO {
@Override
public JSONObject obtenerNivelEstado(NivelEstadoBean nivelEstado) {
System.out.println("NivelEstadoSqlserverDAO: obtenerNivelEstado");
JSONObject jsonObtenerNivelEstado = null;
PreparedStatement ps = null;
ResultSet rs = null;
Connection connection = null;
int codigoNivelEstado = 0;
ResponseHelper response = new ResponseHelper();
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "nivel_estado.codigo_nivel_estado as codigoNivelEstado "
+ "from nivel_estado "
+ "where nivel_estado.codigo_nivel_estudio = ? "
+ "and nivel_estado.codigo_estado_estudio = ? "
+ "and nivel_estado.estado_registro = 1";
ps = connection.prepareStatement(sql);
ps.setInt(1, nivelEstado.getCodigoNivelEstudio());
ps.setInt(2, nivelEstado.getCodigoEstadoEstudio());
rs = ps.executeQuery();
rs.next();
codigoNivelEstado = rs.getInt("codigoNivelEstado");
if (codigoNivelEstado > 0) {
JSONObject getResultedKey = new JSONObject();
getResultedKey.put("getResultedKey", codigoNivelEstado);
response.setStatus(true);
response.setData(getResultedKey);
response.setMessage("Se obtuvo el código correctamente");
} else {
response.setStatus(false);
response.setMessage("No se pudo obtener el código");
}
} 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();
}
}
jsonObtenerNivelEstado = new JSONObject(response);
return jsonObtenerNivelEstado;
}
}
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.NivelEstudioBean;
import trismegistoplanilla.dao.NivelEstudioDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class NivelEstudioMysqlDAO implements NivelEstudioDAO {
@Override
public JSONObject validarExistenciaNivelEstudio(NivelEstudioBean nivelEstudio) {
System.out.println("NivelEstudioSqlserverDAO: validarExistenciaNivelEstudio");
JSONObject jsonValidarExistenciaNivelEstudio = null;
ResponseHelper response = new ResponseHelper();
int existeNivelEstudio = 0;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "count (1) as existeNivelEstudio "
+ "from nivel_estado "
+ "inner join dbo.nivel_estudio ON dbo.nivel_estudio.codigo_nivel_estudio = dbo.nivel_estado.codigo_nivel_estudio "
+ "where nivel_estudio.estado_registro = 1 and nivel_estado.codigo_nivel_estudio = ?";
ps = connection.prepareStatement(sql);
ps.setInt(1, nivelEstudio.getCodigoNivelEstudio());
rs = ps.executeQuery();
rs.next();
existeNivelEstudio = rs.getInt("existeNivelEstudio");
if (existeNivelEstudio > 0) {
response.setStatus(true);
response.setMessage("El nivel estudio seleccionado existe.");
} else {
response.setStatus(false);
response.setMessage("El nivel estudio seleccionado 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();
}
}
jsonValidarExistenciaNivelEstudio = new JSONObject(response);
return jsonValidarExistenciaNivelEstudio;
}
@Override
public JSONObject listarNivelEstudio() {
System.out.println("NivelEstudioSqlserverDAO: listarNivelEstudio");
JSONObject jsonListarNivelEstudio = null;
JSONArray jsonArrayListarNivelEstudio = new JSONArray();
ResponseHelper response = new ResponseHelper();
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "nivel_estudio.codigo_nivel_estudio codigoNivelEstudio, "
+ "nivel_estudio.nombre nombreNivelEstudio "
+ "from nivel_estado "
+ "inner join dbo.nivel_estudio ON dbo.nivel_estudio.codigo_nivel_estudio = dbo.nivel_estado.codigo_nivel_estudio "
+ "where nivel_estudio.estado_registro = 1 "
+ "group by nivel_estudio.codigo_nivel_estudio, nivel_estudio.nombre";
ps = connection.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
NivelEstudioBean nivelEstudio = new NivelEstudioBean();
nivelEstudio.setCodigoNivelEstudio(rs.getInt("codigoNivelEstudio"));
nivelEstudio.setNombre(rs.getString("nombreNivelEstudio"));
JSONObject jsonObjNivelEstudio = new JSONObject(nivelEstudio);
jsonArrayListarNivelEstudio.put(jsonObjNivelEstudio);
}
JSONObject jsonObjEstadoEstudio = new JSONObject();
jsonObjEstadoEstudio.put("nivelestudio", jsonArrayListarNivelEstudio);
response.setStatus(true);
response.setMessage("Los niveles de estudio se han listado correctamente");
response.setData(jsonObjEstadoEstudio);
} 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();
}
}
jsonListarNivelEstudio = new JSONObject(response);
return jsonListarNivelEstudio;
}
}
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.ParentescoBean;
import trismegistoplanilla.dao.ParentescoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class ParentescoMysqlDAO implements ParentescoDAO {
@Override
public JSONObject listarParentesco() {
System.out.println("ParentescoSqlserverDAO: listarParentesco");
JSONObject jsonListarParentesco = null;
JSONArray jsonArrayListarParentesco = new JSONArray();
PreparedStatement ps = null;
ResultSet rs = null;
Connection connection = null;
ResponseHelper response = new ResponseHelper();
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "codigo_parentesco codigoParentesco, "
+ "nombre nombre, "
+ "estado_registro estadoRegistro "
+ "FROM parentesco "
+ "where estado_registro = 1";
ps = connection.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
ParentescoBean parentesco = new ParentescoBean();
parentesco.setCodigoParentesco(rs.getInt("codigoParentesco"));
parentesco.setNombre(rs.getString("nombre"));
parentesco.setEstado_registro(rs.getInt("estadoRegistro"));
JSONObject jsonObjParentesco = new JSONObject(parentesco);
jsonArrayListarParentesco.put(jsonObjParentesco);
}
JSONObject jsonObjParentesco = new JSONObject();
jsonObjParentesco.put("parentescos", jsonArrayListarParentesco);
response.setStatus(true);
response.setMessage("Los parentescos se han listado correctamente");
response.setData(jsonObjParentesco);
} 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();
}
}
jsonListarParentesco = new JSONObject(response);
return jsonListarParentesco;
}
@Override
public JSONObject validarExistenciaParentesco(ParentescoBean parentesco) {
System.out.println("ParentescoSqlserverDAO: validarExistenciaParentesco");
JSONObject jsonValidarExistenciaParentesco = null;
ResponseHelper response = new ResponseHelper();
int existeParentesco = 0;
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
connection = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
String sql
= "select "
+ "count(1) as existeParentesco "
+ "from parentesco "
+ "where codigo_parentesco = ? and estado_registro = 1";
ps = connection.prepareStatement(sql);
ps.setInt(1, parentesco.getCodigoParentesco());
rs = ps.executeQuery();
rs.next();
existeParentesco = rs.getInt("existeParentesco");
if (existeParentesco > 0) {
response.setStatus(true);
response.setMessage("El parentesco seleccionado existe.");
} else {
response.setStatus(false);
response.setMessage("El parentesco seleccionado 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();
}
}
jsonValidarExistenciaParentesco = new JSONObject(response);
return jsonValidarExistenciaParentesco;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.AreaBean;
import trismegistoplanilla.beans.SedeBean;
import trismegistoplanilla.dao.SedeAreaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class SedeAreaMysqlDAO implements SedeAreaDAO {
@Override
public JSONObject obtenerSedeArea(SedeBean s, AreaBean a) {
System.out.println("SedeAreaSqlserverDAO: obtenerSedeArea");
JSONObject JOObtenerSedeArea = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "sede_area.codigo_sede_area codigoSedeArea "
+ "from sede_area "
+ "where sede_area.codigo_sede = ? and sede_area.codigo_area = ? and sede_area.estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, s.getCodigoSede());
ps.setInt(2, a.getCodigoArea());
rs = ps.executeQuery();
rs.next();
int codigoSedeArea = rs.getInt("codigoSedeArea");
if (codigoSedeArea > 0) {
JSONObject objSedeArea = new JSONObject();
objSedeArea.put("getResultedKey", codigoSedeArea);
response.setStatus(true);
response.setMessage("Se encontró el código");
response.setData(objSedeArea);
} else {
response.setStatus(false);
response.setMessage("Error! no se ha podido encontrar el código sede area");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOObtenerSedeArea = new JSONObject(response);
return JOObtenerSedeArea;
}
}
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.SedeBean;
import trismegistoplanilla.dao.SedeDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class SedeMysqlDAO implements SedeDAO {
@Override
public JSONObject listarSede() {
System.out.println("SedeSqlserverDAO: listarSede");
JSONObject JObjectSede = null;
JSONArray jArraySede = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "sede_area.codigo_sede codigoSede, "
+ "sede.nombre nombre, "
+ "sede.direccion direccion, "
+ "razon_social.codigo_razon_social codigoRazonSocial, "
+ "razon_social.abreviatura nombreRazonSocial "
+ "from sede_area "
+ "inner join dbo.sede ON dbo.sede.codigo_sede = dbo.sede_area.codigo_sede "
+ "inner join dbo.razon_social ON dbo.razon_social.codigo_razon_social = dbo.sede.codigo_razon_social "
+ "where sede_area.estado_registro = 1 and sede.estado_registro = 1 "
+ "group by sede_area.codigo_sede, sede.nombre, sede.direccion, razon_social.codigo_razon_social, razon_social.abreviatura, sede.estado_registro";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
SedeBean s = new SedeBean();
s.setCodigoSede(rs.getInt("codigoSede"));
s.setNombre(rs.getString("nombre"));
s.setDireccion(rs.getString("direccion"));
s.setCodigoRazonSocial(rs.getInt("codigoRazonSocial"));
s.setNombreRazonSocial(rs.getString("nombreRazonSocial"));
JSONObject objSede = new JSONObject(s);
jArraySede.put(objSede);
}
JSONObject objSede = new JSONObject();
objSede.put("sedes", jArraySede);
response.setStatus(true);
response.setMessage("Las sedes se listaron correctamente");
response.setData(objSede);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JObjectSede = new JSONObject(response);
return JObjectSede;
}
@Override
public JSONObject validarExistenciaSede(SedeBean s) {
System.out.println("SedeSqlserverDAO: validarExistenciaSede");
JSONObject JObjectValidarExistenciaSede = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "count(1) existeSede "
+ "from sede_area "
+ "where sede_area.estado_registro = 1 and sede_area.codigo_sede = ?";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, s.getCodigoSede());
rs = ps.executeQuery();
rs.next();
int existeSede = 0;
existeSede = rs.getInt("existeSede");
if (existeSede > 0) {
response.setStatus(true);
response.setMessage("La sede seleccionada existe");
} else {
response.setStatus(false);
response.setMessage("Error! La sede 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JObjectValidarExistenciaSede = new JSONObject(response);
return JObjectValidarExistenciaSede;
}
@Override
public JSONObject registrar(JSONObject datos) {
System.out.println("SedeSqlserverDAO: registrar");
JSONObject jObject = null;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = ""
+ "insert into sede (nombre, direccion, codigo_razon_social, 1) "
+ "values (?, ?, ?, 1)";
int resultado = 0;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
cnx.setAutoCommit(false);
ps = cnx.prepareStatement(sql);
int c = 1;
ps.setString(c++, datos.getString("sede"));
ps.setString(c++, datos.getString("direccion"));
ps.setInt(c++, datos.getInt("codigoRazonSocial"));
resultado = ps.executeUpdate();
if (resultado == 1) {
cnx.commit();
response.setStatus(true);
response.setMessage("Se registro la sede correctamente!");
} else {
cnx.rollback();
response.setStatus(false);
response.setMessage("No se puedo registrar la sede");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
@Override
public JSONObject editar(JSONObject datos) {
System.out.println("SedeSqlserverDAO: editar");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
@Override
public JSONObject estado(JSONObject datos) {
System.out.println("SedeSqlserverDAO: estado");
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
@Override
public JSONObject validarNombreAdd(JSONObject datos) {
System.out.println("SedeSqlserverDAO: validarNombreAdd");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select count(1) cantidad "
+ "FROM sede "
+ "where sede.nombre = ?";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("sede"));
rs = ps.executeQuery();
if (rs.next()) {
resultado = rs.getInt("cantidad");
if (resultado == 1) {
response.setStatus(false);
response.setMessage("Ya existe una sede con ese nombre");
} else {
response.setStatus(true);
response.setMessage("Puede proceder a registrar la sede");
}
} else {
response.setStatus(false);
response.setMessage("No se pudo encontrar la sede");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
@Override
public JSONObject validarNombreEdit(JSONObject datos) {
System.out.println("SedeSqlserverDAO: validarNombreEdit");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select count(1) "
+ "FROM sede "
+ "where sede.nombre = ? "
+ "and sede.codigo_sede not in (?)";
int resultado;
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, datos.getString("sede"));
ps.setInt(2, datos.getInt("codigoSede"));
rs = ps.executeQuery();
if (rs.next()) {
resultado = rs.getInt("cantidad");
if (resultado == 1) {
response.setStatus(false);
response.setMessage("Ya existe una sede con ese nombre");
} else {
response.setStatus(true);
response.setMessage("Puede proceder a actualizar la sede");
}
} else {
response.setStatus(false);
response.setMessage("No se pudo encontrar la sede");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
}
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.TipoDocumentoBean;
import trismegistoplanilla.beans.TokenFichaBean;
import trismegistoplanilla.dao.TipoDocumentoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class TipoDocumentoMysqlDAO implements TipoDocumentoDAO {
@Override
public JSONObject listarTipoDocumento() {
System.out.println("TipoDocumentoSqlserverDAO: listarTipoDocumento");
JSONObject jsonObjListarTipoDocumento = null;
JSONArray jsonArrListarTipoDocumento = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql
= "select "
+ "tipo_documento.codigo_tipo_documento as codigoTipoDocumento, "
+ "tipo_documento.descripcion_larga as descripcionLarga, "
+ "tipo_documento.descripcion_corta as descripcionCorta, "
+ "tipo_documento.longitud, "
+ "tipo_documento.tipo_entrada as tipoEntrada, "
+ "case "
+ " when tipo_documento.estado_registro = 1 then 'ACTIVO' "
+ " when tipo_documento.estado_registro = 0 then 'INACTIVO' "
+ " else 'ERROR' "
+ "end as nombreEstadoRegistro "
+ "from tipo_documento "
+ "where tipo_documento.estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
TipoDocumentoBean tipoDocumento = new TipoDocumentoBean();
tipoDocumento.setCodigoTipoDocumento(rs.getInt("codigoTipoDocumento"));
tipoDocumento.setDescripcionLarga(rs.getString("descripcionLarga"));
tipoDocumento.setDescripcionCorta(rs.getString("descripcionCorta"));
tipoDocumento.setLongitud(rs.getString("longitud"));
tipoDocumento.setTipoEntrada(rs.getString("tipoEntrada"));
tipoDocumento.setTipoEntrada(rs.getString("tipoEntrada"));
JSONObject jsonObjTipoDocumento = new JSONObject(tipoDocumento);
jsonArrListarTipoDocumento.put(jsonObjTipoDocumento);
}
JSONObject jsonObjTipodocumento = new JSONObject();
jsonObjTipodocumento.put("tipodocumentos", jsonArrListarTipoDocumento);
response.setStatus(true);
response.setMessage("Los tipos de documentos se han listado correctamente.");
response.setData(jsonObjTipodocumento);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjListarTipoDocumento = new JSONObject(response);
return jsonObjListarTipoDocumento;
}
@Override
public JSONObject validarExistenciaTipoDocumento(TipoDocumentoBean tipoDocumento) {
System.out.println("TipoDocumentoSqlserverDAO: validarExistenciaTipoDocumento");
JSONObject jsonObjValidarExistenciaTipoDocumento = null;
ResponseHelper response = new ResponseHelper();
int existeTipoDocumento = 0;
String sql = ""
+ "select "
+ "count(1) existeTipoDocumento "
+ "from tipo_documento "
+ "where codigo_tipo_documento = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, tipoDocumento.getCodigoTipoDocumento());
rs = ps.executeQuery();
rs.next();
existeTipoDocumento = rs.getInt("existeTipoDocumento");
if (existeTipoDocumento > 0) {
response.setStatus(true);
response.setMessage("El tipo documento seleccionado existe.");
} else if (existeTipoDocumento == 0) {
response.setStatus(false);
response.setMessage("El tipo documento seleccionado 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjValidarExistenciaTipoDocumento = new JSONObject(response);
return jsonObjValidarExistenciaTipoDocumento;
}
@Override
public JSONObject obtenerLongitudTipoEntrdadaTipoDocumento(TipoDocumentoBean tipoDocumento) {
System.out.println("TipoDocumentoSqlserverDAO: obtenerLongitudTipoEntrdadaTipoDocumento");
JSONObject jsonObjObtenerLongitudTipoEntrdadaTipoDocumento = null;
JSONArray jsonArrObtenerLongitudTipoEntrdadaTipoDocumento = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "longitud, "
+ "tipo_entrada TipoEntrada "
+ "from tipo_documento "
+ "where codigo_tipo_documento = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, tipoDocumento.getCodigoTipoDocumento());
rs = ps.executeQuery();
while (rs.next()) {
tipoDocumento.setLongitud(rs.getString("longitud"));
tipoDocumento.setTipoEntrada(rs.getString("TipoEntrada"));
JSONObject jsonObjTipoDocumento = new JSONObject(tipoDocumento);
jsonArrObtenerLongitudTipoEntrdadaTipoDocumento.put(jsonObjTipoDocumento);
}
JSONObject jsonObjTipodocumento = new JSONObject();
jsonObjTipodocumento.put("tipodocumentos", jsonArrObtenerLongitudTipoEntrdadaTipoDocumento);
response.setStatus(true);
response.setMessage("La longitud y tipo de entrada se han listado correctamente.");
response.setData(jsonObjTipodocumento);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerLongitudTipoEntrdadaTipoDocumento = new JSONObject(response);
return jsonObjObtenerLongitudTipoEntrdadaTipoDocumento;
}
@Override
public JSONObject obtenerCodigoTipoDocumento(TokenFichaBean tf) {
System.out.println("TipoDocumentoSqlserverDAO: obtenerCodigoTipoDocumento");
JSONObject jsonObjObtenerCodigoTipoDocumento = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "persona.codigo_tipo_documento codigoTipoDocumento "
+ "from persona "
+ "inner join dbo.ficha ON dbo.ficha.codigo_persona = dbo.persona.codigo_persona "
+ "inner join dbo.token_ficha ON dbo.token_ficha.codigo_ficha = dbo.ficha.codigo_ficha "
+ "where token_ficha.codigo_token_ficha = ? and token_ficha.token = ? and "
+ "persona.estado_registro = 1 and "
+ "ficha.estado_registro = 1 and "
+ "token_ficha.estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, tf.getCodigoTokenFicha());
ps.setString(2, tf.getToken());
rs = ps.executeQuery();
rs.next();
int codigoTipoDocumento = rs.getInt("codigoTipoDocumento");
JSONObject objTipoDocumento = new JSONObject();
objTipoDocumento.put("getResultedKey", codigoTipoDocumento);
if (codigoTipoDocumento > 0) {
response.setStatus(true);
response.setMessage("Enhorabuena!, persona y tipo documento identificado");
response.setData(objTipoDocumento);
} else {
response.setStatus(false);
response.setMessage("Error: no se encontró la identificación de la persona ni el tipo de documento registrado");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerCodigoTipoDocumento = new JSONObject(response);
return jsonObjObtenerCodigoTipoDocumento;
}
}
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.TipoEstadoFichaBean;
import trismegistoplanilla.dao.TipoEstadoFichaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class TipoEstadoFichaMysqlDAO implements TipoEstadoFichaDAO {
@Override
public JSONObject listarTipoEstadoFicha() {
System.out.println("TipoEstadoFichaSqlserverDAO: listarTipoEstadoFicha");
JSONObject JOlistarTipoEstadoFicha = null;
JSONArray JAlistarTipoEstadoFicha = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "codigo_tipo_estado_ficha codigoTipoEstadoFicha, "
+ "nombre nombre, "
+ "descripcion descripcion "
+ "from tipo_estado_ficha "
+ "where estado_registro = 1 "
+ "order by 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
TipoEstadoFichaBean tef = new TipoEstadoFichaBean();
tef.setCodigoTipoEstadoFicha(rs.getInt("codigoTipoEstadoFicha"));
tef.setNombre(rs.getString("nombre"));
tef.setDescripcion(rs.getString("descripcion"));
JSONObject objTipoEstadoFicha = new JSONObject(tef);
JAlistarTipoEstadoFicha.put(objTipoEstadoFicha);
}
JSONObject objTipoEstadoFicha = new JSONObject();
objTipoEstadoFicha.put("tiposEstadoFicha", JAlistarTipoEstadoFicha);
response.setStatus(true);
response.setMessage("Los tipos de estado de ficha se listaron correctamente");
response.setData(objTipoEstadoFicha);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOlistarTipoEstadoFicha = new JSONObject(response);
return JOlistarTipoEstadoFicha;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.json.JSONArray;
import org.json.JSONObject;
import trismegistoplanilla.beans.TipoExpedienteBean;
import trismegistoplanilla.dao.TipoExpedienteDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class TipoExpedienteMysqlDAO implements TipoExpedienteDAO {
@Override
public JSONObject listarTipoExpediente() {
System.out.println("TipoExpedienteSqlserverDAO: listarTipoExpediente");
JSONObject JOlistarTipoExpediente = null;
JSONArray JArrayArea = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "codigo_tipo_expediente codigoTipoExpediente, "
+ "nombre, "
+ "estado_registro estado "
+ "from tipo_expediente";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
TipoExpedienteBean te = new TipoExpedienteBean();
te.setCodigoTipoExpediente(rs.getInt("codigoTipoExpediente"));
te.setNombre(rs.getString("nombre"));
JSONObject obj = new JSONObject(te);
JArrayArea.put(obj);
}
JSONObject obj = new JSONObject();
obj.put("tipoexpedientes", JArrayArea);
response.setStatus(true);
response.setMessage("Los tipo de expediente se listaron correctamente");
response.setData(obj);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOlistarTipoExpediente = new JSONObject(response);
return JOlistarTipoExpediente;
}
@Override
public JSONObject registrarTipoExpediente(TipoExpedienteBean te) {
System.out.println("TipoExpedienteSqlserverDAO: registrarTipoExpediente");
JSONObject JOregistrarTipoExpediente = null;
ResponseHelper response = new ResponseHelper();
String sql = "insert into tipo_expediente (nombre, estado_registro) values (upper(?) ,1)";
Connection conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion.setAutoCommit(false);
// validar existencia de tipo de expediente
JSONObject validarExistenciaTipoExpediente = validarExistenciaTipoExpediente(te);
if (validarExistenciaTipoExpediente.getBoolean("status")) {
response.setStatus(false);
response.setMessage("El tipo de expediente ingresado, ya existe en el sistema");
conexion.rollback();
} else {
ps = conexion.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
ps.setString(1, te.getNombre());
int resultadoRegistroTipoExpediente = ps.executeUpdate();
if (resultadoRegistroTipoExpediente > 0) {
rs = ps.getGeneratedKeys();
rs.next();
int codigoTipoExpediente = rs.getInt(1);
JSONObject objTipoExpediente = new JSONObject();
objTipoExpediente.put("id", codigoTipoExpediente);
objTipoExpediente.put("data", te.getNombre());
response.setStatus(true);
response.setMessage("El tipo de expediente ha sido registrado con exito");
response.setData(objTipoExpediente);
conexion.commit();
} else {
response.setStatus(false);
response.setMessage("Error: no se pudo registrar el tipo de expediente ingresado");
conexion.rollback();
}
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
try {
conexion.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOregistrarTipoExpediente = new JSONObject(response);
return JOregistrarTipoExpediente;
}
@Override
public JSONObject validarExistenciaTipoExpediente(TipoExpedienteBean te) {
System.out.println("TipoExpedienteSqlserverDAO: validarExistenciaTipoExpediente");
JSONObject JOvalidarExistenciaTipoExpediente = null;
ResponseHelper response = new ResponseHelper();
String sql = "select count(1) existe from tipo_expediente where nombre = upper(?)";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setString(1, te.getNombre());
rs = ps.executeQuery();
rs.next();
int existeTipoExpediente = rs.getInt("existe");
if (existeTipoExpediente > 0) {
response.setStatus(true);
} else {
response.setStatus(false);
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOvalidarExistenciaTipoExpediente = new JSONObject(response);
return JOvalidarExistenciaTipoExpediente;
}
@Override
public JSONObject validarTipoExpedienteSeleccionadoByID(JSONArray ja) {
System.out.println("TipoExpedienteSqlserverDAO: validarTipoExpedienteSeleccionadoByID");
JSONObject JOvalidarExistenciaTipoExpediente = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "count(1) existe "
+ "from tipo_expediente "
+ "where codigo_tipo_expediente = ?";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
int existe = 0;
for (int i = 0; i < ja.length(); i++) {
JSONObject obj = ja.getJSONObject(i);
ps.setInt(1, obj.getInt("id"));
rs = ps.executeQuery();
rs.next();
existe = rs.getInt("existe");
if (existe == 0) {
break;
}
}
if (existe > 0) {
response.setStatus(true);
} else {
response.setStatus(false);
response.setMessage("Al parecer ha seleccionado un tipo de expediente que no se encuentra registrardo, por favor seleccione un elemento correcto y vuelva a intentarlo");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOvalidarExistenciaTipoExpediente = new JSONObject(response);
return JOvalidarExistenciaTipoExpediente;
}
}
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.AreaCargoBean;
import trismegistoplanilla.beans.AreaCargoTipoPagoBean;
import trismegistoplanilla.beans.TipoPagoBean;
import trismegistoplanilla.dao.TipoPagoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class TipoPagoMysqlDAO implements TipoPagoDAO {
@Override
public JSONObject listarTipoPago(AreaCargoBean ac) {
System.out.println("TipoPagoSqlserverDAO: listarTipoPago");
JSONObject JOListarTipoPago = null;
JSONArray JAListarTipoPago = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "tipo_pago.codigo_tipo_pago codigoTipoPago, "
+ "tipo_pago.nombre "
+ "from area_cargo_tipo_pago "
+ "inner join dbo.tipo_pago ON dbo.tipo_pago.codigo_tipo_pago = dbo.area_cargo_tipo_pago.codigo_tipo_pago "
+ "where area_cargo_tipo_pago.codigo_area_cargo = ? and area_cargo_tipo_pago.estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, ac.getCodigoAreaCargo());
rs = ps.executeQuery();
while (rs.next()) {
TipoPagoBean tp = new TipoPagoBean();
tp.setCodigoTipoPago(rs.getInt("codigoTipoPago"));
tp.setNombre(rs.getString("nombre"));
JSONObject objTipoPago = new JSONObject(tp);
JAListarTipoPago.put(objTipoPago);
}
JSONObject objTipoPago = new JSONObject();
objTipoPago.put("tipoPagos", JAListarTipoPago);
response.setStatus(true);
response.setMessage("Los tipos de pagos se listaron correctamente");
response.setData(objTipoPago);
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JOListarTipoPago = new JSONObject(response);
return JOListarTipoPago;
}
@Override
public JSONObject validarExistenciaTipoPago(AreaCargoTipoPagoBean actp) {
System.out.println("TipoPagoSqlserverDAO: validarExistenciaTipoPago");
JSONObject JObjectValidarExistenciaTipoPago = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "count(1) exiteTipoPago "
+ "from area_cargo_tipo_pago "
+ "inner join dbo.tipo_pago ON dbo.tipo_pago.codigo_tipo_pago = dbo.area_cargo_tipo_pago.codigo_tipo_pago "
+ "where area_cargo_tipo_pago.codigo_area_cargo = ? and area_cargo_tipo_pago.codigo_tipo_pago = ? and area_cargo_tipo_pago.estado_registro = 1;";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, actp.getCodigoAreaCargo());
ps.setInt(2, actp.getCodigoTipoPago());
rs = ps.executeQuery();
rs.next();
int exiteTipoPago = 0;
exiteTipoPago = rs.getInt("exiteTipoPago");
if (exiteTipoPago > 0) {
response.setStatus(true);
response.setMessage("El tipo de pago seleccionada existe");
} else {
response.setStatus(false);
response.setMessage("Error! El tipo de pago 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
JObjectValidarExistenciaTipoPago = new JSONObject(response);
return JObjectValidarExistenciaTipoPago;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.TokenFichaBean;
import trismegistoplanilla.dao.TokenFichaDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class TokenFichaMysqlDAO implements TokenFichaDAO {
@Override
public JSONObject validarTokenURL(TokenFichaBean tf) {
System.out.println("TokenFichaSqlserverDAO: validarTokenURL");
JSONObject jsonObjValidarTokenURL = null;
ResponseHelper response = new ResponseHelper();
int tokenValidoURL = 0;
String sql = ""
+ "select "
+ "count(1) tokenValidoURL "
+ "from token_ficha "
+ "where codigo_token_ficha = ? and "
+ "token = ? ";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, tf.getCodigoTokenFicha());
ps.setString(2, tf.getToken());
rs = ps.executeQuery();
rs.next();
tokenValidoURL = rs.getInt("tokenValidoURL");
if (tokenValidoURL > 0) {
response.setStatus(true);
response.setMessage("El token es válido");
} else {
response.setStatus(false);
// error token no valido
response.setMessage("El token no existe o ha caducado");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjValidarTokenURL = new JSONObject(response);
return jsonObjValidarTokenURL;
}
@Override
public JSONObject validarToken(TokenFichaBean tf) {
System.out.println("TokenFichaSqlserverDAO: validarToken");
JSONObject jsonObjValidarToken = null;
ResponseHelper response = new ResponseHelper();
int tokenValido = 0;
String sql = ""
+ "select "
+ "count(1) tokenValido "
+ "from token_ficha "
+ "where "
+ "codigo_token_ficha = ? and "
+ "token = ? and "
+ "fecha_expiracion >= getdate() and "
+ "estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
ps.setInt(1, tf.getCodigoTokenFicha());
ps.setString(2, tf.getToken());
rs = ps.executeQuery();
rs.next();
tokenValido = rs.getInt("tokenValido");
if (tokenValido > 0) {
response.setStatus(true);
response.setMessage("El token es válido");
} else {
response.setStatus(false);
response.setMessage("Error, el token no existe o esta inhabilitado");
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjValidarToken = new JSONObject(response);
return jsonObjValidarToken;
}
@Override
public JSONObject desactivarToken(TokenFichaBean tf) {
System.out.println("TokenFichaSqlserverDAO: desactivarToken");
JSONObject jsonObjDesactivarToken = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "update token_ficha "
+ "set estado_registro = 0 "
+ "where codigo_token_ficha = ? and estado_registro = 1";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
conexion.setAutoCommit(false);
ps = conexion.prepareStatement(sql);
ps.setInt(1, tf.getCodigoTokenFicha());
int desactivarToken = ps.executeUpdate();
if (desactivarToken > 0) {
conexion.commit();
response.setStatus(true);
response.setMessage("La token se ha desactivado con éxito.");
} else {
response.setStatus(false);
response.setMessage("Error al desactivar el token, no se ha encontrado ningún registro.");
conexion.rollback();
}
} 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 (conexion != null) {
conexion.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjDesactivarToken = new JSONObject(response);
return jsonObjDesactivarToken;
}
@Override
public JSONObject obtenerSedeAreaCargo(JSONObject datos) {
System.out.println("TokenFichaSqlserverDAO: obtenerSedeAreaCargo");
JSONObject jObject;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = ""
+ "select top 1 "
+ "token_ficha.codigo_sede_area codigoSedeArea, "
+ "token_ficha.codigo_area_cargo codigoAreaCargo, "
+ "sede.nombre nombreSede, "
+ "area.nombre nombreArea, "
+ "cargo.nombre nombreCargo "
+ "FROM token_ficha "
+ "inner join ficha ON ficha.codigo_ficha = token_ficha.codigo_ficha "
+ "inner join persona ON persona.codigo_persona = ficha.codigo_persona "
+ "inner join sede_area on token_ficha.codigo_sede_area = sede_area.codigo_sede_area "
+ "inner join sede ON sede.codigo_sede = sede_area.codigo_sede "
+ "inner join area ON area.codigo_area = sede_area.codigo_area "
+ "inner join area_cargo on token_ficha.codigo_area_cargo = area_cargo.codigo_area_cargo "
+ "inner join cargo ON cargo.codigo_cargo = area_cargo.codigo_cargo "
+ "where persona.codigo_persona = ? "
+ "order by 1 desc";
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setInt(1, datos.getInt("codigoPersona"));
rs = ps.executeQuery();
if (rs.next()) {
JSONObject jsonObject = new JSONObject();
jsonObject.put("codigoSedeArea", rs.getInt("codigoSedeArea"));
jsonObject.put("codigoAreaCargo", rs.getInt("codigoAreaCargo"));
jsonObject.put("sede", rs.getString("nombreSede"));
jsonObject.put("area", rs.getString("nombreArea"));
jsonObject.put("cargo", rs.getString("nombreCargo"));
response.setStatus(true);
response.setMessage("Se obtuvo la sede, area y cargo del personal");
response.setData(new JSONObject().put("datosAdministrativos", jsonObject));
} else {
response.setStatus(false);
response.setMessage("No se encontraron sede - area - cargos del personal.");
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jObject = new JSONObject(response);
return jObject;
}
}
package trismegistoplanilla.mysqldao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONObject;
import trismegistoplanilla.beans.TrabajadorResponsableBean;
import trismegistoplanilla.dao.TrabajadorResponsableDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;
public class TrabajadorResponsableMysqlDAO implements TrabajadorResponsableDAO {
@Override
public JSONObject registrarTrabajadorResponsable(TrabajadorResponsableBean trabajadorResponsable) {
System.out.println("TrabajadorResponsableSqlserverDAO: registrarTrabajadorResponsable");
JSONObject jsonRegistrarTrabajadorResponsable = null;
PreparedStatement ps = null;
Connection cnx = null;
ResponseHelper response = new ResponseHelper();
int resultadoRegistroTrabajadorResponsable;
try {
String sql
= "insert into trabajador_responsable "
+ "(codigo_planilla_real, apellido_paterno, apellido_materno, nombre, dni, codigo_usuario, estado_registro) "
+ "values (?,LTRIM(RTRIM(UPPER(?))),LTRIM(RTRIM(UPPER(?))),LTRIM(RTRIM(UPPER(?))),?,?,1)";
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
cnx.setAutoCommit(false);
ps = cnx.prepareStatement(sql);
ps.setInt(1, trabajadorResponsable.getCodigoPlanillaReal());
ps.setString(2, trabajadorResponsable.getApellidoPaterno());
ps.setString(3, trabajadorResponsable.getApellidoMaterno());
ps.setString(4, trabajadorResponsable.getNombre());
ps.setString(5, trabajadorResponsable.getDni());
ps.setInt(6, trabajadorResponsable.getCodigoUsuario());
resultadoRegistroTrabajadorResponsable = ps.executeUpdate();
if (resultadoRegistroTrabajadorResponsable == 0) {
response.setStatus(false);
cnx.rollback();
} else {
response.setStatus(true);
cnx.commit();
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
} finally {
try {
if (ps != null) {
ps.close();
}
if (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonRegistrarTrabajadorResponsable = new JSONObject(response);
return jsonRegistrarTrabajadorResponsable;
}
@Override
public JSONObject validarExistenciaTrabajadorPorDni(TrabajadorResponsableBean trabajadorResponsable) {
System.out.println("TrabajadorResponsableSqlserverDAO: validarExistenciaTrabajadorPorDni");
JSONObject jsonRegistrarTrabajadorResponsable = null;
PreparedStatement ps = null;
ResultSet rs = null;
Connection cnx = null;
ResponseHelper response = new ResponseHelper();
int existeTrabajador;
try {
String sql
= "select count(1) as existeTrabajador "
+ "from trabajador_responsable "
+ "where trabajador_responsable.dni = ? and estado_registro = 1";
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setString(1, trabajadorResponsable.getDni());
rs = ps.executeQuery();
rs.next();
existeTrabajador = rs.getInt("existeTrabajador");
if (existeTrabajador > 0) {
response.setStatus(true);
response.setMessage("El trabajador existe");
} else if (existeTrabajador == 0) {
response.setStatus(false);
response.setMessage("El trabajador no existe");
}
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonRegistrarTrabajadorResponsable = new JSONObject(response);
return jsonRegistrarTrabajadorResponsable;
}
@Override
public JSONObject obtenerDatosTrabajadorResponsable(int codigoPlanillaReal) {
System.out.println("TrabajadorResponsableSqlserverDAO: obtenerDatosTrabajadorResponsable");
JSONObject jsonObjObtenerSedeAreaCargoPorCodigoPlanilla = null;
PreparedStatement ps = null;
ResultSet rs = null;
Connection cnx = null;
ResponseHelper response = new ResponseHelper();
try {
String sql
= "select "
+ "sede.nombre nombreSede, "
+ "area.nombre nombreArea, "
+ "cargo.nombre nombreCargo, "
+ "isnull(trabajador_responsable.correo,'responsablesacooliveros@yopmail.com') correo "
+ "from trabajador_responsable "
+ "inner join sede_area on trabajador_responsable.codigo_sede_area = sede_area.codigo_sede_area "
+ "inner join sede on sede_area.codigo_sede = sede.codigo_sede "
+ "inner join area on sede_area.codigo_area = area.codigo_area "
+ "inner join area_cargo on trabajador_responsable.codigo_area_cargo = area_cargo.codigo_area_cargo "
+ "inner join cargo on area_cargo.codigo_cargo = cargo.codigo_cargo "
+ "where trabajador_responsable.codigo_planilla_real = ?";
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setInt(1, codigoPlanillaReal);
rs = ps.executeQuery();
if (rs.next()) {
TrabajadorResponsableBean tResponsable = new TrabajadorResponsableBean();
tResponsable.setNombreSede(rs.getString("nombreSede"));
tResponsable.setNombreArea(rs.getString("nombreArea"));
tResponsable.setNombreCargo(rs.getString("nombreCargo"));
tResponsable.setCorreo(rs.getString("correo"));
JSONObject jsonObjTrabajadorResponsable = new JSONObject(tResponsable);
response.setStatus(true);
response.setData(jsonObjTrabajadorResponsable);
}
} 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 (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonObjObtenerSedeAreaCargoPorCodigoPlanilla = new JSONObject(response);
return jsonObjObtenerSedeAreaCargoPorCodigoPlanilla;
}
@Override
public JSONObject obtenerCorreoTrabajadorResponsable(int codigoFicha) {
System.out.println("TrabajadorResponsableSqlserverDAO: obtenerCorreoTrabajadorResponsable");
JSONObject jsonReturn = null;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
PreparedStatement ps = null;
ResultSet rs = null;
String correo = "", sql = ""
+ "select top 1 "
+ "trabajador_responsable.correo correo "
+ "FROM persona "
+ "inner join ficha ON ficha.codigo_persona = persona.codigo_persona "
+ "inner join estado_ficha ON estado_ficha.codigo_ficha = ficha.codigo_ficha "
+ "inner join trabajador_responsable on estado_ficha.codigo_usuario = trabajador_responsable.codigo_usuario "
+ "where ficha.codigo_ficha = ? "
+ "order by 1 desc";
try {
cnx = MysqlDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = cnx.prepareStatement(sql);
ps.setInt(1, codigoFicha);
rs = ps.executeQuery();
if (rs.next()) {
correo = rs.getString("correo");
}
JSONObject jOCorreo = new JSONObject();
jOCorreo.put("getResult", correo);
response.setStatus(true);
response.setData(jOCorreo);
} catch (SQLException e) {
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
e.printStackTrace();
} finally {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (cnx != null) {
cnx.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
jsonReturn = new JSONObject(response);
return jsonReturn;
}
}
......@@ -20,6 +20,7 @@ public class AreaSqlserverDAO implements AreaDAO {
JSONObject JObjectArea = null;
JSONArray JArrayArea = new JSONArray();
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "SELECT "
+ " sede_area.codigo_area codigoArea, "
......@@ -34,9 +35,11 @@ public class AreaSqlserverDAO implements AreaDAO {
+ "GROUP BY "
+ " sede_area.codigo_area, "
+ " area.nombre";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = SqlserverDAOFactory.obtenerConexion(Variables.BD_NAME);
ps = conexion.prepareStatement(sql);
......
......@@ -2530,6 +2530,7 @@ public class FichaSqlserverDAO implements FichaDAO {
System.out.println("FichaSqlserverDAO: verificarExistenciaFichaAnulada");
JSONObject JOverificarExistenciaFichaAnulada = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "count(1) existeFichaAnulada "
......@@ -2547,6 +2548,7 @@ public class FichaSqlserverDAO implements FichaDAO {
Connection conexion = SqlserverDAOFactory.obtenerConexion(Variables.BD_NAME);
PreparedStatement ps = null;
ResultSet rs = null;
try {
ps = conexion.prepareStatement(sql);
ps.setInt(1, p.getCodigoTipoDocumento());
......@@ -2582,6 +2584,7 @@ public class FichaSqlserverDAO implements FichaDAO {
e.printStackTrace();
}
}
JOverificarExistenciaFichaAnulada = new JSONObject(response);
return JOverificarExistenciaFichaAnulada;
}
......@@ -2591,6 +2594,7 @@ public class FichaSqlserverDAO implements FichaDAO {
System.out.println("FichaSqlserverDAO: obtenerCodigoPersonaPorTipoDocNroDoc");
JSONObject JOobtenerCodigoPersonaPorTipoDocNroDoc = null;
ResponseHelper response = new ResponseHelper();
String sql = ""
+ "select "
+ "codigo_persona codigoPersona "
......@@ -2603,12 +2607,14 @@ public class FichaSqlserverDAO implements FichaDAO {
Connection conexion = SqlserverDAOFactory.obtenerConexion(Variables.BD_NAME);
PreparedStatement ps = null;
ResultSet rs = null;
try {
ps = conexion.prepareStatement(sql);
ps.setInt(1, p.getCodigoTipoDocumento());
ps.setString(2, p.getNumeroDocumento());
rs = ps.executeQuery();
rs.next();
int codigoPersona = rs.getInt("codigoPersona");
if (codigoPersona > 0) {
JSONObject objPersona = new JSONObject();
......
......@@ -52,16 +52,12 @@ public class SqlserverDAOFactory extends DAOFactory {
public static Connection obtenerConexion(String base) {
Connection conexion = null;
String user = "";
String pwd = "";
String url = "";
String user;
String pwd;
String url;
if (base.equalsIgnoreCase("planillabd")) {
user = "sa";
// url = "jdbc:sqlserver://172.16.2.118:1433;databaseName=planillabd";
// pwd = "Saco1357$";
// url = "jdbc:sqlserver://172.16.2.20:1433;databaseName=planillabd";
// pwd = "S3rv1d0r";
url = "jdbc:sqlserver://172.16.0.5:1433;databaseName=planillabd";
pwd = "Saco1357$";
try {
......@@ -70,6 +66,7 @@ public class SqlserverDAOFactory extends DAOFactory {
e.printStackTrace();
}
}
return conexion;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment