Skip to content

T
trismegisto-planilla
Commit 04eb47a3 by Juan José Rojas Rojas
Options

[ADD] sqlserver to mysql

parent a8559080
Showing with 93 additions and 95 deletions
src/java/trismegistoplanilla/mysqldao/AreaCargoMysqlDAO.java
......@@ -15,7 +15,7 @@ public class AreaCargoMysqlDAO implements AreaCargoDAO {
@Override
public JSONObject obtenerAreaCargo(AreaBean a, CargoBean c) {
System.out.println("AreaCargo MysqlDAO: obtenerAreaCargo");
System.out.println("AreaCargoMysqlDAO: obtenerAreaCargo");
JSONObject JOObtenerAreaCargo = null;
ResponseHelper response = new ResponseHelper();
......@@ -75,7 +75,7 @@ public class AreaCargoMysqlDAO implements AreaCargoDAO {
@Override
public JSONObject asignarAreaCargo(JSONObject datos) {
System.out.println("AreaCargo MysqlDAO: asignarAreaCargo");
System.out.println("AreaCargoMysqlDAO: asignarAreaCargo");
JSONObject jObject = null;
ResponseHelper response = new ResponseHelper();
Connection cnx = null;
......
src/java/trismegistoplanilla/mysqldao/PersonaMysqlDAO.java
......@@ -28,11 +28,14 @@ public class PersonaMysqlDAO implements PersonaDAO {
ResponseHelper response = new ResponseHelper();
int existeNumeroDocumento = 0;
String sql = ""
+ "select "
+ "count(1) existeNumeroDocumento "
+ "from persona "
+ "where estado_registro = 1 and codigo_tipo_documento = ? and numero_documento = ?";
String sql = "SELECT "
+ " count(1) existeNumeroDocumento "
+ "FROM "
+ " personal "
+ "WHERE "
+ " retirado = 1 "
+ "AND codigo_tipo_documento = ? "
+ "AND dni = ?";
Connection conexion = null;
PreparedStatement ps = null;
......@@ -55,7 +58,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
......@@ -71,6 +74,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
e.printStackTrace();
}
}
jsonObjValidarExistenciaNumeroDocumento = new JSONObject(response);
return jsonObjValidarExistenciaNumeroDocumento;
}
......@@ -82,15 +86,18 @@ public class PersonaMysqlDAO implements PersonaDAO {
ResponseHelper response = new ResponseHelper();
int existeCorreoElectronico = 0;
String sql = ""
+ "select "
+ "count(1) existeCorreoElectronico "
+ "from persona "
+ "where estado_registro = 1 and correo = ?";
String sql = "SELECT "
+ " count(1) existeCorreoElectronico "
+ "FROM "
+ " personal "
+ "WHERE "
+ " retirado = 0 "
+ "AND email = ?";
Connection conexion = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conexion = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
ps = conexion.prepareStatement(sql);
......@@ -108,7 +115,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
......@@ -124,6 +131,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
e.printStackTrace();
}
}
jsonObjValidarExistenciaCorreoElectronico = new JSONObject(response);
return jsonObjValidarExistenciaCorreoElectronico;
}
......@@ -134,26 +142,27 @@ public class PersonaMysqlDAO implements PersonaDAO {
JSONObject jsonObjRegistrarPersona = null;
ResponseHelper response = new ResponseHelper();
String sqlPersona = ""
+ "insert into persona "
+ "(apellido_paterno, "
+ "apellido_materno, "
+ "nombre, "
+ "codigo_tipo_documento, "
+ "numero_documento, "
+ "correo, "
+ "is_default_mail, "
+ "estado_registro) "
+ "values "
+ "("
+ "upper(rtrim(ltrim(?))), "
+ "upper(rtrim(ltrim(?))), "
+ "upper(rtrim(ltrim(?))), "
+ "upper(rtrim(ltrim(?))), "
+ "upper(rtrim(ltrim(?))), "
+ "upper(rtrim(ltrim(?))), "
+ "upper(rtrim(ltrim(?))), "
+ "1)";
String sqlPersona = "INSERT INTO personal ( "
+ " apellidoPaterno, " // apellido_paterno
+ " apellidoMaterno, " // apellido_materno
+ " nombre, "
+ " codigo_tipo_documento, "
+ " dni, " // numero_documento
+ " email, " // correo
+ " is_default_mail, "
+ " retirado " // estado_registro
+ ") "
+ "VALUES "
+ " ( "
+ " upper(rtrim(ltrim(?))), "
+ " upper(rtrim(ltrim(?))), "
+ " upper(rtrim(ltrim(?))), "
+ " upper(rtrim(ltrim(?))), "
+ " upper(rtrim(ltrim(?))), "
+ " upper(rtrim(ltrim(?))), "
+ " upper(rtrim(ltrim(?))), "
+ " 0 "
+ " )";
Connection conexion = null;
PreparedStatement psPersona = null, psFicha = null, psEstadoFicha = null, psTokenFicha = null, psObtenerToken = null, psObtenerCodigoFicha = null;
......@@ -178,15 +187,12 @@ public class PersonaMysqlDAO implements PersonaDAO {
int codigoPersona = rsPersona.getInt(1);
/*-************ REGISTRAR FICHA **************-*/
String sqlFicha = ""
+ "insert into ficha ( "
+ "codigo_persona "
+ ",estado_registro "
String sqlFicha = "INSERT INTO ficha ( "
+ " codigo_persona, "
+ " estado_registro "
+ ") "
+ "values ( "
+ "? "
+ ",1 "
+ ")";
+ "VALUES "
+ " (?, 1)";
conexion.setAutoCommit(false);
psFicha = conexion.prepareStatement(sqlFicha, Statement.RETURN_GENERATED_KEYS);
......@@ -199,20 +205,15 @@ public class PersonaMysqlDAO implements PersonaDAO {
int codigoFicha = rsFicha.getInt(1);
/*-************ REGISTRAR ESTADO DE FICHA **************-*/
String sqlEstadoFicha = ""
+ "insert into estado_ficha ( "
+ "codigo_ficha "
+ ",codigo_tipo_estado_ficha "
+ ",fecha_registro "
+ ",codigo_usuario "
+ ",estado_registro "
+ ") VALUES ( "
+ "?, "
+ "1, "
+ "getdate(), "
+ "?, "
+ "1 "
+ ")";
String sqlEstadoFicha = "INSERT INTO estado_ficha ( "
+ " codigo_ficha, "
+ " codigo_tipo_estado_ficha, "
+ " fecha_registro, "
+ " codigo_usuario, "
+ " estado_registro "
+ ") "
+ "VALUES "
+ " (?, 1, NOW(), ?, 1)";
conexion.setAutoCommit(false);
psEstadoFicha = conexion.prepareStatement(sqlEstadoFicha);
......@@ -222,28 +223,24 @@ public class PersonaMysqlDAO implements PersonaDAO {
if (resultRegistrarEstadoFicha > 0) {
/*-************ REGISTRAR TOKEN DE FICHA **************-*/
String sqlTokenFicha = ""
+ "insert into token_ficha "
+ " ( "
+ "codigo_ficha "
+ ",codigo_verificacion "
+ ",fecha_creacion "
+ ",fecha_expiracion "
+ ",token "
+ ",codigo_sede_area"
+ ",codigo_area_cargo"
+ ",estado_registro "
String sqlTokenFicha = "INSERT INTO token_ficha ( "
+ " codigo_ficha, "
+ " codigo_verificacion, "
+ " fecha_creacion, "
+ " fecha_expiracion, "
+ " token, "
+ " codigo_sede_area, "
+ " codigo_area_cargo, "
+ " estado_registro "
+ ") "
+ "values ( "
+ "? "
+ ",? "
+ ",getdate() "
+ ",dateadd(dd, 1, getdate()) "
+ ",lower(newid()) "
+ ",?"
+ ",?"
+ ",1 "
+ ")";
+ "VALUES "
+ " ( "
+ " ? ,?, "
+ " now(), "
+ " timestampadd (DAY, 1, now()), "
+ " lower(uuid()) ,? ,?, "
+ " 1 "
+ " )";
String CodeVerification = GenerateCodeVerification.randomString(6); // almacenar el codigo de verificacion a enviar
conexion.setAutoCommit(false);
......@@ -260,11 +257,13 @@ public class PersonaMysqlDAO implements PersonaDAO {
int codigoTokenFicha = rsTokenFicha.getInt(1);
/*-************ OBTENER TOKEN FICHA **************-*/
String sqlGetToken = ""
+ "select "
+ "token "
+ "from token_ficha "
+ "where codigo_token_ficha = ? and estado_registro = 1";
String sqlGetToken = "SELECT "
+ " token "
+ "FROM "
+ " token_ficha "
+ "WHERE "
+ " codigo_token_ficha = ? "
+ "AND estado_registro = 1";
conexion.setAutoCommit(false);
psObtenerToken = conexion.prepareStatement(sqlGetToken);
......@@ -310,7 +309,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} catch (Exception e) {
e.printStackTrace();
response.setStatus(false);
......@@ -406,7 +405,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
......@@ -460,7 +459,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rsUpdatePersona != null) {
......@@ -521,7 +520,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
......@@ -596,7 +595,7 @@ public class PersonaMysqlDAO implements PersonaDAO {
} catch (SQLException e) {
e.printStackTrace();
response.setStatus(false);
response.setMessage("Error: " + e.getMessage() + " \n Error Code: [" + e.getErrorCode() + "]");
response.setMessage("Error: " + e.getMessage() + " Error Code: [" + e.getErrorCode() + "]");
} finally {
try {
if (rs != null) {
......
src/java/trismegistoplanilla/mysqldao/VacanteMysqlDAO.java
......@@ -332,7 +332,7 @@ public class VacanteMysqlDAO implements VacanteDAO {
+ " vacante.cantidad - ( "
+ " ( "
+ " SELECT "
+ " COUNT (1) "
+ " COUNT(1) "
+ " FROM "
+ " ficha_laboral fl "
+ " WHERE "
......@@ -341,7 +341,7 @@ public class VacanteMysqlDAO implements VacanteDAO {
+ " AND fl.codigo_area_cargo = vacante.codigo_area_cargo "
+ " ) + ( "
+ " SELECT "
+ " COUNT (1) "
+ " COUNT(1) "
+ " FROM "
+ " token_ficha tf "
+ " WHERE "
......
src/java/trismegistoplanilla/servicesMysql/ConfiguracionFichaService.java
......@@ -6,7 +6,7 @@ import trismegistoplanilla.dao.DAOFactory;
public class ConfiguracionFichaService {
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.SQL_SERVER);
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.MYSQL);
ConfiguracionFichaDAO objConfiguracionFichaDAO = factory.getConfiguracionFichaDAO();
public JSONObject getDefaultMail() {
......
src/java/trismegistoplanilla/servicesMysql/PersonaService.java
......@@ -9,7 +9,7 @@ import trismegistoplanilla.dao.PersonaDAO;
public class PersonaService {
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.SQL_SERVER);
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.MYSQL);
PersonaDAO objPersonaDAO = factory.getPersonaDAO();
public JSONObject validarExistenciaNumeroDocumento(PersonaBean p) {
......
src/java/trismegistoplanilla/servicesMysql/SedeService.java
......@@ -7,7 +7,7 @@ import trismegistoplanilla.dao.SedeDAO;
public class SedeService {
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.SQL_SERVER);
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.MYSQL);
SedeDAO objSedeDAO = factory.getSedeDAO();
public JSONObject listarSede() {
......
src/java/trismegistoplanilla/servicesMysql/TipoDocumentoService.java
......@@ -8,7 +8,7 @@ import trismegistoplanilla.dao.TipoDocumentoDAO;
public class TipoDocumentoService {
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.SQL_SERVER);
DAOFactory factory = DAOFactory.getDAOFactory(DAOFactory.MYSQL);
TipoDocumentoDAO objTipoDocumentoDAO = factory.getTipoDocumentoDAO();
public JSONObject listarTipoDocumento() {
......
src/java/trismegistoplanilla/servlets/ConfiguracionFichaServlet.java
......@@ -20,7 +20,6 @@ public class ConfiguracionFichaServlet extends HttpServlet {
if (accion.equals("getDefaultMail")) {
getDefaultMail(request, response);
}
}
private void getDefaultMail(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
......
src/java/trismegistoplanilla/servlets/PersonaServlet.java
......@@ -13,7 +13,7 @@ import pe.siso.webservicesseguridad.webservices.UsuarioBean;
import trismegistoplanilla.beans.EstadoFichaBean;
import trismegistoplanilla.beans.PersonaBean;
import trismegistoplanilla.beans.TokenFichaBean;
import trismegistoplanilla.services.PersonaService;
import trismegistoplanilla.servicesMysql.PersonaService;
import trismegistoplanilla.services.TipoDocumentoService;
import trismegistoplanilla.utilities.ParamsValidation;
......
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