Separando un poco las clases de los modelos

This commit is contained in:
Daniel Cortes
2018-12-28 22:04:22 -03:00
parent e555ab9106
commit 0f2598db91
24 changed files with 315 additions and 400 deletions

View File

@@ -14,11 +14,12 @@ database_type = sqlite
# debe corresponder con el sistema de base de datos seleccionado en database_type # debe corresponder con el sistema de base de datos seleccionado en database_type
#database_uri = jdbc:mysql://localhost/caja?user=root&password=lagging&useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC #database_uri = jdbc:mysql://localhost/caja?user=root&password=lagging&useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
database_uri = jdbc:sqlite:/home/ryuuji/src/caja/database.sqlite database_uri = jdbc:sqlite:database.sqlite
# look_and_feel elige el look and feel que intentara utilizar la aplicacion, si el seleccionado no funciona en el sistema operativo se hara fallback a metal. # look_and_feel elige el look and feel que intentara utilizar la aplicacion, si el seleccionado no funciona en el sistema operativo se hara fallback a metal.
look_and_feel = javax.swing.plaf.metal.MetalLookAndFeel look_and_feel = javax.swing.plaf.metal.MetalLookAndFeel
#look_and_feel = com.sun.java.swing.plaf.motif.MotifLookAndFeel
#look_and_feel = com.sun.java.swing.plaf.gtk.GTKLookAndFeel #look_and_feel = com.sun.java.swing.plaf.gtk.GTKLookAndFeel
#look_and_feel = com.sun.java.swing.plaf.windows.WindowsLookAndFeel #look_and_feel = com.sun.java.swing.plaf.windows.WindowsLookAndFeel

Binary file not shown.

View File

@@ -38,7 +38,7 @@ public class Properties {
private Properties() { private Properties() {
try { try {
this.props = new java.util.Properties(); this.props = new java.util.Properties();
FileInputStream in = new FileInputStream("conf"); FileInputStream in = new FileInputStream("conf.properties");
this.props.load(in); this.props.load(in);
in.close(); in.close();
} catch (IOException e) { } catch (IOException e) {

View File

@@ -24,13 +24,32 @@
package danielcortes.xyz.models.caja; package danielcortes.xyz.models.caja;
import danielcortes.xyz.data.ConnectionHolder;
import danielcortes.xyz.data.SQLiteConnectionHolder;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.time.LocalDate; import java.time.LocalDate;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface CajaDAO { public abstract class CajaDAO {
List<Caja> findAll(); protected ConnectionHolder connectionHolder;
Caja findById(int id);
Caja findByFecha(LocalDate fecha); public abstract List<Caja> findAll();
boolean insertCaja(Caja caja); public abstract Caja findById(int id);
boolean updateCaja(Caja caja); public abstract Caja findByFecha(LocalDate fecha);
public abstract boolean insertCaja(Caja caja);
public abstract boolean updateCaja(Caja caja);
protected List<Caja> cajasFromResultSet(ResultSet rs) throws SQLException {
List<Caja> cajaList = new ArrayList<>();
while (rs.next()) {
Caja caja = new Caja();
caja.setId(rs.getInt("id"));
caja.setFecha(LocalDate.parse(rs.getString("fecha")));
cajaList.add(caja);
}
return cajaList;
}
} }

View File

@@ -31,18 +31,17 @@ import java.time.LocalDate;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlCajaDAO implements CajaDAO { public class MysqlCajaDAO extends CajaDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlCajaDAO() { public MysqlCajaDAO() {
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<Caja> findAll() { public List<Caja> findAll() {
List<Caja> cajaList = new ArrayList<>(); List<Caja> cajaList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from caja"); PreparedStatement ps = conn.prepareStatement("select * from caja");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -61,7 +60,7 @@ public class MysqlCajaDAO implements CajaDAO {
public Caja findById(int id) { public Caja findById(int id) {
Caja caja = null; Caja caja = null;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from caja where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from caja where id = ?");
ps.setInt(1, id); ps.setInt(1, id);
@@ -83,7 +82,7 @@ public class MysqlCajaDAO implements CajaDAO {
public Caja findByFecha(LocalDate fecha) { public Caja findByFecha(LocalDate fecha) {
Caja caja = null; Caja caja = null;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from caja where fecha = ?"); PreparedStatement ps = conn.prepareStatement("select * from caja where fecha = ?");
ps.setObject(1, fecha); ps.setObject(1, fecha);
@@ -92,7 +91,7 @@ public class MysqlCajaDAO implements CajaDAO {
List<Caja> cajaList = this.cajasFromResultSet(rs); List<Caja> cajaList = this.cajasFromResultSet(rs);
if(cajaList.size() > 0){ if (cajaList.size() > 0) {
caja = cajaList.get(0); caja = cajaList.get(0);
} }
@@ -109,7 +108,7 @@ public class MysqlCajaDAO implements CajaDAO {
public boolean insertCaja(Caja caja) { public boolean insertCaja(Caja caja) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into caja (fecha) values (?)"); PreparedStatement ps = conn.prepareStatement("insert into caja (fecha) values (?)");
ps.setObject(1, caja.getFecha()); ps.setObject(1, caja.getFecha());
@@ -135,7 +134,7 @@ public class MysqlCajaDAO implements CajaDAO {
public boolean updateCaja(Caja caja) { public boolean updateCaja(Caja caja) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("update caja set fecha = ? where id = ?"); PreparedStatement ps = conn.prepareStatement("update caja set fecha = ? where id = ?");
ps.setObject(1, caja.getFecha()); ps.setObject(1, caja.getFecha());
ps.setInt(2, caja.getId()); ps.setInt(2, caja.getId());
@@ -150,15 +149,4 @@ public class MysqlCajaDAO implements CajaDAO {
} }
return updates > 0; return updates > 0;
} }
private List<Caja> cajasFromResultSet(ResultSet rs) throws SQLException {
List<Caja> cajaList = new ArrayList<>();
while (rs.next()) {
Caja caja = new Caja();
caja.setId(rs.getInt("id"));
caja.setFecha(rs.getObject("fecha", LocalDate.class));
cajaList.add(caja);
}
return cajaList;
}
} }

View File

@@ -30,17 +30,12 @@ import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteCajaDAO implements CajaDAO { public class SQLiteCajaDAO extends CajaDAO {
private SQLiteConnectionHolder connectionHolder; public SQLiteCajaDAO () {
public SQLiteCajaDAO() {
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -157,16 +152,4 @@ public class SQLiteCajaDAO implements CajaDAO {
} }
return updates > 0; return updates > 0;
} }
private List<Caja> cajasFromResultSet(ResultSet rs) throws SQLException {
List<Caja> cajaList = new ArrayList<>();
while (rs.next()) {
Caja caja = new Caja();
caja.setId(rs.getInt("id"));
caja.setFecha(LocalDate.parse(rs.getString("fecha")));
cajaList.add(caja);
}
return cajaList;
}
} }

View File

@@ -24,17 +24,43 @@
package danielcortes.xyz.models.documentos; package danielcortes.xyz.models.documentos;
import danielcortes.xyz.data.ConnectionHolder;
import danielcortes.xyz.data.MysqlConnectionHolder;
import danielcortes.xyz.models.caja.Caja; import danielcortes.xyz.models.caja.Caja;
import danielcortes.xyz.models.caja.CajaDAO;
import danielcortes.xyz.models.caja.MysqlCajaDAO;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface DocumentosDAO { public abstract class DocumentosDAO {
List<Documentos> findAll(); protected ConnectionHolder connectionHolder;
Documentos findById(int id);
Documentos findByCaja(Caja caja);
boolean insertDocumentos(Documentos documentos); public abstract List<Documentos> findAll();
boolean insertDefaultDocumentos(Documentos documentos); public abstract Documentos findById(int id);
boolean updateDocumentos(Documentos documentos); public abstract Documentos findByCaja(Caja caja);
boolean deleteDocumentos(Documentos documentos);
public abstract boolean insertDocumentos(Documentos documentos);
public abstract boolean insertDefaultDocumentos(Documentos documentos);
public abstract boolean updateDocumentos(Documentos documentos);
public abstract boolean deleteDocumentos(Documentos documentos);
protected List<Documentos> documentosFromResultSet(ResultSet rs) throws SQLException {
List<Documentos> documentosList = new ArrayList<>();
while (rs.next()) {
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(rs.getInt("caja_id"));
Documentos documentos = new Documentos();
documentos.setCaja(caja);
documentos.setId(rs.getInt("id"));
documentos.setCheques(rs.getInt("cheques"));
documentos.setTarjetas(rs.getInt("tarjetas"));
documentosList.add(documentos);
}
return documentosList;
}
} }

View File

@@ -36,18 +36,17 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlDocumentosDAO implements DocumentosDAO { public class MysqlDocumentosDAO extends DocumentosDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlDocumentosDAO() { public MysqlDocumentosDAO() {
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<Documentos> findAll() { public List<Documentos> findAll() {
List<Documentos> documentosList = new ArrayList<>(); List<Documentos> documentosList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from documentos"); PreparedStatement ps = conn.prepareStatement("select * from documentos");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -66,7 +65,7 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
public Documentos findById(int id) { public Documentos findById(int id) {
Documentos documentos = null; Documentos documentos = null;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from documentos where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from documentos where id = ?");
ps.setInt(1, id); ps.setInt(1, id);
@@ -90,7 +89,7 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
public Documentos findByCaja(Caja caja) { public Documentos findByCaja(Caja caja) {
Documentos documentos = null; Documentos documentos = null;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from documentos where caja_id = ?"); PreparedStatement ps = conn.prepareStatement("select * from documentos where caja_id = ?");
ps.setInt(1, caja.getId()); ps.setInt(1, caja.getId());
@@ -114,7 +113,7 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
public boolean insertDocumentos(Documentos documentos) { public boolean insertDocumentos(Documentos documentos) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into documentos (cheques, tarjetas, caja_id) values (?,?,?)"); PreparedStatement ps = conn.prepareStatement("insert into documentos (cheques, tarjetas, caja_id) values (?,?,?)");
ps.setInt(1, documentos.getCheques()); ps.setInt(1, documentos.getCheques());
ps.setInt(2, documentos.getTarjetas()); ps.setInt(2, documentos.getTarjetas());
@@ -142,7 +141,7 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
public boolean insertDefaultDocumentos(Documentos documentos) { public boolean insertDefaultDocumentos(Documentos documentos) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into documentos (cheques, tarjetas, caja_id) values (0,0,?)"); PreparedStatement ps = conn.prepareStatement("insert into documentos (cheques, tarjetas, caja_id) values (0,0,?)");
ps.setInt(1, documentos.getCaja().getId()); ps.setInt(1, documentos.getCaja().getId());
@@ -168,7 +167,7 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
public boolean updateDocumentos(Documentos documentos) { public boolean updateDocumentos(Documentos documentos) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("update documentos set tarjetas = ?, cheques = ?, caja_id = ? where id = ?"); PreparedStatement ps = conn.prepareStatement("update documentos set tarjetas = ?, cheques = ?, caja_id = ? where id = ?");
ps.setInt(1, documentos.getTarjetas()); ps.setInt(1, documentos.getTarjetas());
ps.setInt(2, documentos.getCheques()); ps.setInt(2, documentos.getCheques());
@@ -189,7 +188,7 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
public boolean deleteDocumentos(Documentos documentos) { public boolean deleteDocumentos(Documentos documentos) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("delete from documentos where id = ?"); PreparedStatement ps = conn.prepareStatement("delete from documentos where id = ?");
ps.setInt(1, documentos.getId()); ps.setInt(1, documentos.getId());
@@ -204,20 +203,4 @@ public class MysqlDocumentosDAO implements DocumentosDAO {
return updates > 0; return updates > 0;
} }
private List<Documentos> documentosFromResultSet(ResultSet rs) throws SQLException {
List<Documentos> documentosList = new ArrayList<>();
while (rs.next()) {
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(rs.getInt("caja_id"));
Documentos documentos = new Documentos();
documentos.setCaja(caja);
documentos.setId(rs.getInt("id"));
documentos.setCheques(rs.getInt("cheques"));
documentos.setTarjetas(rs.getInt("tarjetas"));
documentosList.add(documentos);
}
return documentosList;
}
} }

View File

@@ -37,9 +37,7 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteDocumentosDAO implements DocumentosDAO{ public class SQLiteDocumentosDAO extends DocumentosDAO {
private ConnectionHolder connectionHolder;
public SQLiteDocumentosDAO() { public SQLiteDocumentosDAO() {
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -204,21 +202,4 @@ public class SQLiteDocumentosDAO implements DocumentosDAO{
} }
return updates > 0; return updates > 0;
} }
private List<Documentos> documentosFromResultSet(ResultSet rs) throws SQLException {
List<Documentos> documentosList = new ArrayList<>();
while (rs.next()) {
CajaDAO cajaDAO = new SQLiteCajaDAO();
Caja caja = cajaDAO.findById(rs.getInt("caja_id"));
Documentos documentos = new Documentos();
documentos.setCaja(caja);
documentos.setId(rs.getInt("id"));
documentos.setCheques(rs.getInt("cheques"));
documentos.setTarjetas(rs.getInt("tarjetas"));
documentosList.add(documentos);
}
return documentosList;
}
} }

View File

@@ -24,17 +24,50 @@
package danielcortes.xyz.models.efectivo; package danielcortes.xyz.models.efectivo;
import danielcortes.xyz.data.ConnectionHolder;
import danielcortes.xyz.data.MysqlConnectionHolder;
import danielcortes.xyz.models.caja.Caja; import danielcortes.xyz.models.caja.Caja;
import danielcortes.xyz.models.caja.CajaDAO;
import danielcortes.xyz.models.caja.MysqlCajaDAO;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface EfectivoDAO { public abstract class EfectivoDAO {
List<Efectivo> findAll(); protected ConnectionHolder connectionHolder;
Efectivo findById(int id);
Efectivo findByCaja(Caja caja);
boolean insertEfectivo(Efectivo efectivo); public abstract List<Efectivo> findAll();
boolean insertDefaultEfectivo(Efectivo efectivo); public abstract Efectivo findById(int id);
boolean updateEfectivo(Efectivo efectivo); public abstract Efectivo findByCaja(Caja caja);
boolean deleteEfectivo(Efectivo efectivo);
public abstract boolean insertEfectivo(Efectivo efectivo);
public abstract boolean insertDefaultEfectivo(Efectivo efectivo);
public abstract boolean updateEfectivo(Efectivo efectivo);
public abstract boolean deleteEfectivo(Efectivo efectivo);
protected List<Efectivo> efectivosFromResultSet(ResultSet rs) throws SQLException {
List<Efectivo> efectivoList = new ArrayList<>();
while (rs.next()) {
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(rs.getInt("caja_id"));
Efectivo efectivo = new Efectivo();
efectivo.setCaja(caja);
efectivo.setId(rs.getInt("id"));
efectivo.setVeinteMil(rs.getInt("veinte_mil"));
efectivo.setDiezMil(rs.getInt("diez_mil"));
efectivo.setCincoMil(rs.getInt("cinco_mil"));
efectivo.setDosMil(rs.getInt("dos_mil"));
efectivo.setMil(rs.getInt("mil"));
efectivo.setQuinientos(rs.getInt("quinientos"));
efectivo.setCien(rs.getInt("cien"));
efectivo.setCincuenta(rs.getInt("cincuenta"));
efectivo.setDiez(rs.getInt("diez"));
efectivoList.add(efectivo);
}
return efectivoList;
}
} }

View File

@@ -36,18 +36,16 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlEfectivoDAO implements EfectivoDAO { public class MysqlEfectivoDAO extends EfectivoDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlEfectivoDAO() { public MysqlEfectivoDAO() {
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<Efectivo> findAll() { public List<Efectivo> findAll() {
List<Efectivo> efectivoList = new ArrayList<>(); List<Efectivo> efectivoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from efectivos"); PreparedStatement ps = conn.prepareStatement("select * from efectivos");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -67,7 +65,7 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
public Efectivo findById(int id) { public Efectivo findById(int id) {
Efectivo efectivo = null; Efectivo efectivo = null;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from efectivos where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from efectivos where id = ?");
ps.setInt(1, id); ps.setInt(1, id);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -88,7 +86,7 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
public Efectivo findByCaja(Caja caja) { public Efectivo findByCaja(Caja caja) {
Efectivo efectivo = null; Efectivo efectivo = null;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from efectivos where caja_id = ?"); PreparedStatement ps = conn.prepareStatement("select * from efectivos where caja_id = ?");
ps.setInt(1, caja.getId()); ps.setInt(1, caja.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -112,7 +110,7 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
public boolean insertEfectivo(Efectivo efectivo) { public boolean insertEfectivo(Efectivo efectivo) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into efectivos (veinte_mil, diez_mil, cinco_mil, dos_mil, mil, quinientos, cien, cincuenta, diez, caja_id) values (?,?,?,?,?,?,?,?,?,?)"); PreparedStatement ps = conn.prepareStatement("insert into efectivos (veinte_mil, diez_mil, cinco_mil, dos_mil, mil, quinientos, cien, cincuenta, diez, caja_id) values (?,?,?,?,?,?,?,?,?,?)");
ps.setInt(1, efectivo.getVeinteMil()); ps.setInt(1, efectivo.getVeinteMil());
ps.setInt(2, efectivo.getDiezMil()); ps.setInt(2, efectivo.getDiezMil());
@@ -147,7 +145,7 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
public boolean insertDefaultEfectivo(Efectivo efectivo) { public boolean insertDefaultEfectivo(Efectivo efectivo) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into efectivos (veinte_mil, diez_mil, cinco_mil, dos_mil, mil, quinientos, cien, cincuenta, diez, caja_id) values (0,0,0,0,0,0,0,0,0,?)"); PreparedStatement ps = conn.prepareStatement("insert into efectivos (veinte_mil, diez_mil, cinco_mil, dos_mil, mil, quinientos, cien, cincuenta, diez, caja_id) values (0,0,0,0,0,0,0,0,0,?)");
ps.setInt(1, efectivo.getCaja().getId()); ps.setInt(1, efectivo.getCaja().getId());
@@ -173,7 +171,7 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
public boolean updateEfectivo(Efectivo efectivo) { public boolean updateEfectivo(Efectivo efectivo) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("update efectivos set veinte_mil = ?, diez_mil = ?, cinco_mil = ?, dos_mil = ?, mil = ?, quinientos = ?, cien = ?, cincuenta = ?, diez = ?, caja_id = ? where id = ?"); PreparedStatement ps = conn.prepareStatement("update efectivos set veinte_mil = ?, diez_mil = ?, cinco_mil = ?, dos_mil = ?, mil = ?, quinientos = ?, cien = ?, cincuenta = ?, diez = ?, caja_id = ? where id = ?");
ps.setInt(1, efectivo.getVeinteMil()); ps.setInt(1, efectivo.getVeinteMil());
ps.setInt(2, efectivo.getDiezMil()); ps.setInt(2, efectivo.getDiezMil());
@@ -202,7 +200,7 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
public boolean deleteEfectivo(Efectivo efectivo) { public boolean deleteEfectivo(Efectivo efectivo) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("delete from efectivos where id = ?"); PreparedStatement ps = conn.prepareStatement("delete from efectivos where id = ?");
ps.setInt(1, efectivo.getId()); ps.setInt(1, efectivo.getId());
@@ -217,27 +215,4 @@ public class MysqlEfectivoDAO implements EfectivoDAO {
return updates > 0; return updates > 0;
} }
private List<Efectivo> efectivosFromResultSet(ResultSet rs) throws SQLException {
List<Efectivo> efectivoList = new ArrayList<>();
while (rs.next()) {
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(rs.getInt("caja_id"));
Efectivo efectivo = new Efectivo();
efectivo.setCaja(caja);
efectivo.setId(rs.getInt("id"));
efectivo.setVeinteMil(rs.getInt("veinte_mil"));
efectivo.setDiezMil(rs.getInt("diez_mil"));
efectivo.setCincoMil(rs.getInt("cinco_mil"));
efectivo.setDosMil(rs.getInt("dos_mil"));
efectivo.setMil(rs.getInt("mil"));
efectivo.setQuinientos(rs.getInt("quinientos"));
efectivo.setCien(rs.getInt("cien"));
efectivo.setCincuenta(rs.getInt("cincuenta"));
efectivo.setDiez(rs.getInt("diez"));
efectivoList.add(efectivo);
}
return efectivoList;
}
} }

View File

@@ -37,9 +37,7 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteEfectivoDAO implements EfectivoDAO{ public class SQLiteEfectivoDAO extends EfectivoDAO {
private ConnectionHolder connectionHolder;
public SQLiteEfectivoDAO() { public SQLiteEfectivoDAO() {
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -217,28 +215,4 @@ public class SQLiteEfectivoDAO implements EfectivoDAO{
} }
return updates > 0; return updates > 0;
} }
private List<Efectivo> efectivosFromResultSet(ResultSet rs) throws SQLException {
List<Efectivo> efectivoList = new ArrayList<>();
while (rs.next()) {
CajaDAO cajaDAO = new SQLiteCajaDAO();
Caja caja = cajaDAO.findById(rs.getInt("caja_id"));
Efectivo efectivo = new Efectivo();
efectivo.setCaja(caja);
efectivo.setId(rs.getInt("id"));
efectivo.setVeinteMil(rs.getInt("veinte_mil"));
efectivo.setDiezMil(rs.getInt("diez_mil"));
efectivo.setCincoMil(rs.getInt("cinco_mil"));
efectivo.setDosMil(rs.getInt("dos_mil"));
efectivo.setMil(rs.getInt("mil"));
efectivo.setQuinientos(rs.getInt("quinientos"));
efectivo.setCien(rs.getInt("cien"));
efectivo.setCincuenta(rs.getInt("cincuenta"));
efectivo.setDiez(rs.getInt("diez"));
efectivoList.add(efectivo);
}
return efectivoList;
}
} }

View File

@@ -24,23 +24,57 @@
package danielcortes.xyz.models.egreso; package danielcortes.xyz.models.egreso;
import danielcortes.xyz.data.ConnectionHolder;
import danielcortes.xyz.models.caja.Caja; import danielcortes.xyz.models.caja.Caja;
import danielcortes.xyz.models.caja.CajaDAO;
import danielcortes.xyz.models.caja.MysqlCajaDAO;
import danielcortes.xyz.models.egreso.Egreso; import danielcortes.xyz.models.egreso.Egreso;
import danielcortes.xyz.models.tipo_egreso.MysqlTipoEgresoDAO;
import danielcortes.xyz.models.tipo_egreso.TipoEgreso; import danielcortes.xyz.models.tipo_egreso.TipoEgreso;
import danielcortes.xyz.models.tipo_egreso.TipoEgresoDAO;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface EgresoDAO { public abstract class EgresoDAO {
List<Egreso> findAll(); protected ConnectionHolder connectionHolder;
List<Egreso> findById(int id);
List<Egreso> findByCaja(Caja caja);
List<Egreso> findByNro(String nro);
List<Egreso> findByTipoEgreso(TipoEgreso tipoEgreso);
boolean insertEgreso(Egreso egreso); public abstract List<Egreso> findAll();
boolean updateEgreso(Egreso egreso); public abstract List<Egreso> findById(int id);
boolean deleteEgreso(Egreso egreso); public abstract List<Egreso> findByCaja(Caja caja);
public abstract List<Egreso> findByNro(String nro);
public abstract List<Egreso> findByTipoEgreso(TipoEgreso tipoEgreso);
int getTotalEgreso(Caja caja); public abstract boolean insertEgreso(Egreso egreso);
public abstract boolean updateEgreso(Egreso egreso);
public abstract boolean deleteEgreso(Egreso egreso);
public abstract int getTotalEgreso(Caja caja);
List<Egreso> egresosFromResultSet(ResultSet rs) throws SQLException {
ArrayList<Egreso> egresoList = new ArrayList<>();
while(rs.next()){
int tipoEgresoId = rs.getInt("tipo_egreso_id");
TipoEgresoDAO tipoEgresoDAO = new MysqlTipoEgresoDAO();
TipoEgreso tipoEgreso = tipoEgresoDAO.findById(tipoEgresoId).get(0);
int cajaId = rs.getInt("caja_id");
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(cajaId);
Egreso egreso = new Egreso();
egreso.setId(rs.getInt("id"));
egreso.setNro(rs.getString("nro"));
egreso.setDescripcion(rs.getString("descripcion"));
egreso.setValor(rs.getInt("valor"));
egreso.setTipoEgreso(tipoEgreso);
egreso.setCaja(caja);
egresoList.add(egreso);
}
return egresoList;
}
} }

View File

@@ -39,18 +39,17 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlEgresoDAO implements EgresoDAO { public class MysqlEgresoDAO extends EgresoDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlEgresoDAO(){ public MysqlEgresoDAO(){
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<Egreso> findAll() { public List<Egreso> findAll() {
List<Egreso> egresoList = new ArrayList<>(); List<Egreso> egresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from egresos"); PreparedStatement ps = conn.prepareStatement("select * from egresos");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -69,7 +68,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public List<Egreso> findById(int id) { public List<Egreso> findById(int id) {
List<Egreso> egresoList = new ArrayList<>(); List<Egreso> egresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from egresos where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from egresos where id = ?");
ps.setInt(1,id); ps.setInt(1,id);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -89,7 +88,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public List<Egreso> findByCaja(Caja caja) { public List<Egreso> findByCaja(Caja caja) {
List<Egreso> egresoList = new ArrayList<>(); List<Egreso> egresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from egresos where caja_id = ?"); PreparedStatement ps = conn.prepareStatement("select * from egresos where caja_id = ?");
ps.setInt(1, caja.getId()); ps.setInt(1, caja.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -110,7 +109,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public List<Egreso> findByNro(String nro) { public List<Egreso> findByNro(String nro) {
List<Egreso> egresoList = new ArrayList<>(); List<Egreso> egresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from egresos where nro = ?"); PreparedStatement ps = conn.prepareStatement("select * from egresos where nro = ?");
ps.setString(1, nro); ps.setString(1, nro);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -130,7 +129,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public List<Egreso> findByTipoEgreso(TipoEgreso tipoEgreso) { public List<Egreso> findByTipoEgreso(TipoEgreso tipoEgreso) {
List<Egreso> egresoList = new ArrayList<>(); List<Egreso> egresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from egresos where tipo_egreso_id = ?"); PreparedStatement ps = conn.prepareStatement("select * from egresos where tipo_egreso_id = ?");
ps.setInt(1, tipoEgreso.getId()); ps.setInt(1, tipoEgreso.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -150,7 +149,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public boolean insertEgreso(Egreso egreso) { public boolean insertEgreso(Egreso egreso) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into egresos (nro, descripcion, valor, tipo_egreso_id, caja_id) values (?,?,?,?,?)"); PreparedStatement ps = conn.prepareStatement("insert into egresos (nro, descripcion, valor, tipo_egreso_id, caja_id) values (?,?,?,?,?)");
ps.setString(1,egreso.getNro()); ps.setString(1,egreso.getNro());
ps.setString(2,egreso.getDescripcion()); ps.setString(2,egreso.getDescripcion());
@@ -179,7 +178,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public boolean updateEgreso(Egreso egreso) { public boolean updateEgreso(Egreso egreso) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("update egresos set nro = ?, descripcion = ?, valor = ?, tipo_egreso_id = ?, caja_id = ? where id = ? "); PreparedStatement ps = conn.prepareStatement("update egresos set nro = ?, descripcion = ?, valor = ?, tipo_egreso_id = ?, caja_id = ? where id = ? ");
ps.setString(1,egreso.getNro()); ps.setString(1,egreso.getNro());
ps.setString(2,egreso.getDescripcion()); ps.setString(2,egreso.getDescripcion());
@@ -203,7 +202,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public boolean deleteEgreso(Egreso egreso) { public boolean deleteEgreso(Egreso egreso) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("delete from egresos where id = ? "); PreparedStatement ps = conn.prepareStatement("delete from egresos where id = ? ");
ps.setInt(1, egreso.getId()); ps.setInt(1, egreso.getId());
@@ -222,7 +221,7 @@ public class MysqlEgresoDAO implements EgresoDAO {
public int getTotalEgreso(Caja caja) { public int getTotalEgreso(Caja caja) {
int total = 0; int total = 0;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select sum(valor) from egresos where caja_id = ?"); PreparedStatement ps = conn.prepareStatement("select sum(valor) from egresos where caja_id = ?");
ps.setInt(1, caja.getId()); ps.setInt(1, caja.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -239,28 +238,4 @@ public class MysqlEgresoDAO implements EgresoDAO {
return total; return total;
} }
private List<Egreso> egresosFromResultSet(ResultSet rs) throws SQLException {
ArrayList<Egreso> egresoList = new ArrayList<>();
while(rs.next()){
int tipoEgresoId = rs.getInt("tipo_egreso_id");
TipoEgresoDAO tipoEgresoDAO = new MysqlTipoEgresoDAO();
TipoEgreso tipoEgreso = tipoEgresoDAO.findById(tipoEgresoId).get(0);
int cajaId = rs.getInt("caja_id");
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(cajaId);
Egreso egreso = new Egreso();
egreso.setId(rs.getInt("id"));
egreso.setNro(rs.getString("nro"));
egreso.setDescripcion(rs.getString("descripcion"));
egreso.setValor(rs.getInt("valor"));
egreso.setTipoEgreso(tipoEgreso);
egreso.setCaja(caja);
egresoList.add(egreso);
}
return egresoList;
}
} }

View File

@@ -40,9 +40,7 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteEgresoDAO implements EgresoDAO{ public class SQLiteEgresoDAO extends EgresoDAO {
private ConnectionHolder connectionHolder;
public SQLiteEgresoDAO(){ public SQLiteEgresoDAO(){
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -238,30 +236,4 @@ public class SQLiteEgresoDAO implements EgresoDAO{
} }
return total; return total;
} }
private List<Egreso> egresosFromResultSet(ResultSet rs) throws SQLException {
ArrayList<Egreso> egresoList = new ArrayList<>();
while(rs.next()){
int tipoEgresoId = rs.getInt("tipo_egreso_id");
TipoEgresoDAO tipoEgresoDAO = new SQLiteTipoEgresoDAO();
TipoEgreso tipoEgreso = tipoEgresoDAO.findById(tipoEgresoId).get(0);
int cajaId = rs.getInt("caja_id");
CajaDAO cajaDAO = new SQLiteCajaDAO();
Caja caja = cajaDAO.findById(cajaId);
Egreso egreso = new Egreso();
egreso.setId(rs.getInt("id"));
egreso.setNro(rs.getString("nro"));
egreso.setDescripcion(rs.getString("descripcion"));
egreso.setValor(rs.getInt("valor"));
egreso.setTipoEgreso(tipoEgreso);
egreso.setCaja(caja);
egresoList.add(egreso);
}
return egresoList;
}
} }

View File

@@ -25,18 +25,55 @@
package danielcortes.xyz.models.ingreso; package danielcortes.xyz.models.ingreso;
import danielcortes.xyz.data.ConnectionHolder;
import danielcortes.xyz.models.caja.Caja; import danielcortes.xyz.models.caja.Caja;
import danielcortes.xyz.models.caja.CajaDAO;
import danielcortes.xyz.models.caja.MysqlCajaDAO;
import danielcortes.xyz.models.tipo_ingreso.MysqlTipoIngresoDAO;
import danielcortes.xyz.models.tipo_ingreso.TipoIngreso; import danielcortes.xyz.models.tipo_ingreso.TipoIngreso;
import danielcortes.xyz.models.tipo_ingreso.TipoIngresoDAO;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface IngresoDAO { public abstract class IngresoDAO {
List<Ingreso> findAll(); protected ConnectionHolder connectionHolder;
List<Ingreso> findByCaja(Caja caja);
List<Ingreso> findById(int id); public abstract List<Ingreso> findAll();
List<Ingreso> findByTipoIngreso(TipoIngreso tipoIngreso); public abstract List<Ingreso> findByCaja(Caja caja);
boolean insertIngreso(Ingreso ingreso); public abstract List<Ingreso> findById(int id);
boolean updateIngreso(Ingreso ingreso); public abstract List<Ingreso> findByTipoIngreso(TipoIngreso tipoIngreso);
boolean deleteIngreso(Ingreso ingreso);
int getTotalIngreso(Caja caja); public abstract boolean insertIngreso(Ingreso ingreso);
public abstract boolean updateIngreso(Ingreso ingreso);
public abstract boolean deleteIngreso(Ingreso ingreso);
public abstract int getTotalIngreso(Caja caja);
List<Ingreso> ingresosFromResultSet(ResultSet rs) throws SQLException {
ArrayList<Ingreso> ingresosList = new ArrayList<>();
while(rs.next()){
int tipoIngresoId = rs.getInt("tipo_ingreso_id");
TipoIngresoDAO tipoEgresoDAO = new MysqlTipoIngresoDAO();
TipoIngreso tipoIngreso = tipoEgresoDAO.findById(tipoIngresoId).get(0);
int cajaId = rs.getInt("caja_id");
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(cajaId);
Ingreso ingreso = new Ingreso();
ingreso.setId(rs.getInt("id"));
ingreso.setValor(rs.getInt("valor"));
ingreso.setNroInicial(rs.getString("nro_inicial"));
ingreso.setNroFinal(rs.getString("nro_final"));
ingreso.setTipoIngreso(tipoIngreso);
ingreso.setCaja(caja);
ingresosList.add(ingreso);
}
return ingresosList;
}
} }

View File

@@ -39,18 +39,17 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlIngresoDAO implements IngresoDAO{ public class MysqlIngresoDAO extends IngresoDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlIngresoDAO(){ public MysqlIngresoDAO(){
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<Ingreso> findAll() { public List<Ingreso> findAll() {
List<Ingreso> ingresosList = new ArrayList<>(); List<Ingreso> ingresosList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from ingresos"); PreparedStatement ps = conn.prepareStatement("select * from ingresos");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -69,7 +68,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public List<Ingreso> findByCaja(Caja caja) { public List<Ingreso> findByCaja(Caja caja) {
List<Ingreso> ingresosList = new ArrayList<>(); List<Ingreso> ingresosList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from ingresos where caja_id = ?"); PreparedStatement ps = conn.prepareStatement("select * from ingresos where caja_id = ?");
ps.setInt(1, caja.getId()); ps.setInt(1, caja.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -89,7 +88,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public List<Ingreso> findById(int id) { public List<Ingreso> findById(int id) {
List<Ingreso> ingresosList = new ArrayList<>(); List<Ingreso> ingresosList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from ingresos where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from ingresos where id = ?");
ps.setInt(1, id); ps.setInt(1, id);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -109,7 +108,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public List<Ingreso> findByTipoIngreso(TipoIngreso tipoIngreso) { public List<Ingreso> findByTipoIngreso(TipoIngreso tipoIngreso) {
List<Ingreso> ingresosList = new ArrayList<>(); List<Ingreso> ingresosList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select ingresos.* from ingresos inner join tipos_ingreso on (ingresos.tipo_ingreso_id = tipos_ingreso.id) where ingresos.tipo_ingreso_id = ?"); PreparedStatement ps = conn.prepareStatement("select ingresos.* from ingresos inner join tipos_ingreso on (ingresos.tipo_ingreso_id = tipos_ingreso.id) where ingresos.tipo_ingreso_id = ?");
ps.setInt(1, tipoIngreso.getId()); ps.setInt(1, tipoIngreso.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -129,7 +128,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public boolean insertIngreso(Ingreso ingreso) { public boolean insertIngreso(Ingreso ingreso) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("insert into ingresos (valor, nro_inicial, nro_final, tipo_ingreso_id, caja_id) values (?,?,?,?,?)"); PreparedStatement ps = conn.prepareStatement("insert into ingresos (valor, nro_inicial, nro_final, tipo_ingreso_id, caja_id) values (?,?,?,?,?)");
ps.setInt(1, ingreso.getValor()); ps.setInt(1, ingreso.getValor());
ps.setString(2, ingreso.getNroInicial()); ps.setString(2, ingreso.getNroInicial());
@@ -158,7 +157,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public boolean updateIngreso(Ingreso ingreso) { public boolean updateIngreso(Ingreso ingreso) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("update ingresos set valor = ? , nro_inicial = ?, nro_final = ?, tipo_ingreso_id = ?, caja_id = ? where id = ?"); PreparedStatement ps = conn.prepareStatement("update ingresos set valor = ? , nro_inicial = ?, nro_final = ?, tipo_ingreso_id = ?, caja_id = ? where id = ?");
ps.setInt(1,ingreso.getValor()); ps.setInt(1,ingreso.getValor());
ps.setString(2, ingreso.getNroInicial()); ps.setString(2, ingreso.getNroInicial());
@@ -182,7 +181,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public boolean deleteIngreso(Ingreso ingreso) { public boolean deleteIngreso(Ingreso ingreso) {
int updates; int updates;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("delete from ingresos where id = ?"); PreparedStatement ps = conn.prepareStatement("delete from ingresos where id = ?");
ps.setInt(1,ingreso.getId()); ps.setInt(1,ingreso.getId());
updates = ps.executeUpdate(); updates = ps.executeUpdate();
@@ -199,7 +198,7 @@ public class MysqlIngresoDAO implements IngresoDAO{
public int getTotalIngreso(Caja caja) { public int getTotalIngreso(Caja caja) {
int total = 0; int total = 0;
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select sum(valor) from ingresos where caja_id = ?"); PreparedStatement ps = conn.prepareStatement("select sum(valor) from ingresos where caja_id = ?");
ps.setInt(1, caja.getId()); ps.setInt(1, caja.getId());
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -216,28 +215,4 @@ public class MysqlIngresoDAO implements IngresoDAO{
return total; return total;
} }
private List<Ingreso> ingresosFromResultSet(ResultSet rs) throws SQLException {
ArrayList<Ingreso> ingresosList = new ArrayList<>();
while(rs.next()){
int tipoIngresoId = rs.getInt("tipo_ingreso_id");
TipoIngresoDAO tipoEgresoDAO = new MysqlTipoIngresoDAO();
TipoIngreso tipoIngreso = tipoEgresoDAO.findById(tipoIngresoId).get(0);
int cajaId = rs.getInt("caja_id");
CajaDAO cajaDAO = new MysqlCajaDAO();
Caja caja = cajaDAO.findById(cajaId);
Ingreso ingreso = new Ingreso();
ingreso.setId(rs.getInt("id"));
ingreso.setValor(rs.getInt("valor"));
ingreso.setNroInicial(rs.getString("nro_inicial"));
ingreso.setNroFinal(rs.getString("nro_final"));
ingreso.setTipoIngreso(tipoIngreso);
ingreso.setCaja(caja);
ingresosList.add(ingreso);
}
return ingresosList;
}
} }

View File

@@ -40,9 +40,7 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteIngresoDAO implements IngresoDAO{ public class SQLiteIngresoDAO extends IngresoDAO {
private ConnectionHolder connectionHolder;
public SQLiteIngresoDAO(){ public SQLiteIngresoDAO(){
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -216,29 +214,4 @@ public class SQLiteIngresoDAO implements IngresoDAO{
} }
return total; return total;
} }
private List<Ingreso> ingresosFromResultSet(ResultSet rs) throws SQLException {
ArrayList<Ingreso> ingresosList = new ArrayList<>();
while(rs.next()){
int tipoIngresoId = rs.getInt("tipo_ingreso_id");
TipoIngresoDAO tipoEgresoDAO = new SQLiteTipoIngresoDAO();
TipoIngreso tipoIngreso = tipoEgresoDAO.findById(tipoIngresoId).get(0);
int cajaId = rs.getInt("caja_id");
CajaDAO cajaDAO = new SQLiteCajaDAO();
Caja caja = cajaDAO.findById(cajaId);
Ingreso ingreso = new Ingreso();
ingreso.setId(rs.getInt("id"));
ingreso.setValor(rs.getInt("valor"));
ingreso.setNroInicial(rs.getString("nro_inicial"));
ingreso.setNroFinal(rs.getString("nro_final"));
ingreso.setTipoIngreso(tipoIngreso);
ingreso.setCaja(caja);
ingresosList.add(ingreso);
}
return ingresosList;
}
} }

View File

@@ -33,22 +33,21 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlTipoEgresoDAO implements TipoEgresoDAO { public class MysqlTipoEgresoDAO extends TipoEgresoDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlTipoEgresoDAO(){ public MysqlTipoEgresoDAO(){
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<TipoEgreso> findAll() { public List<TipoEgreso> findAll() {
List<TipoEgreso> tipoEgresoList = new ArrayList<>(); List<TipoEgreso> tipoEgresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso"); PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
tipoEgresoList = this.TipoEgresoFromResultSet(rs); tipoEgresoList = this.tipoEgresoFromResultSet(rs);
rs.close(); rs.close();
ps.close(); ps.close();
@@ -59,17 +58,16 @@ public class MysqlTipoEgresoDAO implements TipoEgresoDAO {
return tipoEgresoList; return tipoEgresoList;
} }
@Override @Override
public List<TipoEgreso> findById(int id) { public List<TipoEgreso> findById(int id) {
List<TipoEgreso> tipoEgresoList = new ArrayList<>(); List<TipoEgreso> tipoEgresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso where id = ?");
ps.setInt(1, id); ps.setInt(1, id);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
tipoEgresoList = this.TipoEgresoFromResultSet(rs); tipoEgresoList = this.tipoEgresoFromResultSet(rs);
rs.close(); rs.close();
ps.close(); ps.close();
@@ -84,12 +82,12 @@ public class MysqlTipoEgresoDAO implements TipoEgresoDAO {
public List<TipoEgreso> findByNombre(String nombre) { public List<TipoEgreso> findByNombre(String nombre) {
List<TipoEgreso> tipoEgresoList = new ArrayList<>(); List<TipoEgreso> tipoEgresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso where nombre = ?"); PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso where nombre = ?");
ps.setString(1, nombre); ps.setString(1, nombre);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
tipoEgresoList = this.TipoEgresoFromResultSet(rs); tipoEgresoList = this.tipoEgresoFromResultSet(rs);
rs.close(); rs.close();
ps.close(); ps.close();
@@ -114,15 +112,4 @@ public class MysqlTipoEgresoDAO implements TipoEgresoDAO {
public boolean deleteTipoEgreso(TipoEgreso tipoEgreso) { public boolean deleteTipoEgreso(TipoEgreso tipoEgreso) {
return false; return false;
} }
private List<TipoEgreso> TipoEgresoFromResultSet(ResultSet rs) throws SQLException {
ArrayList<TipoEgreso> tipoEgresoList = new ArrayList<>();
while(rs.next()){
TipoEgreso tipoEgreso = new TipoEgreso();
tipoEgreso.setId(rs.getInt("id"));
tipoEgreso.setNombre(rs.getString("nombre"));
tipoEgresoList.add(tipoEgreso);
}
return tipoEgresoList;
}
} }

View File

@@ -34,9 +34,7 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteTipoEgresoDAO implements TipoEgresoDAO{ public class SQLiteTipoEgresoDAO extends TipoEgresoDAO {
private ConnectionHolder connectionHolder;
public SQLiteTipoEgresoDAO(){ public SQLiteTipoEgresoDAO(){
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -49,7 +47,7 @@ public class SQLiteTipoEgresoDAO implements TipoEgresoDAO{
PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso"); PreparedStatement ps = conn.prepareStatement("select * from tipos_egreso");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
tipoEgresoList = this.TipoEgresoFromResultSet(rs); tipoEgresoList = this.tipoEgresoFromResultSet(rs);
rs.close(); rs.close();
ps.close(); ps.close();
@@ -69,7 +67,7 @@ public class SQLiteTipoEgresoDAO implements TipoEgresoDAO{
ps.setInt(1, id); ps.setInt(1, id);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
tipoEgresoList = this.TipoEgresoFromResultSet(rs); tipoEgresoList = this.tipoEgresoFromResultSet(rs);
rs.close(); rs.close();
ps.close(); ps.close();
@@ -89,7 +87,7 @@ public class SQLiteTipoEgresoDAO implements TipoEgresoDAO{
ps.setString(1, nombre); ps.setString(1, nombre);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
tipoEgresoList = this.TipoEgresoFromResultSet(rs); tipoEgresoList = this.tipoEgresoFromResultSet(rs);
rs.close(); rs.close();
ps.close(); ps.close();
@@ -115,14 +113,4 @@ public class SQLiteTipoEgresoDAO implements TipoEgresoDAO{
return false; return false;
} }
private List<TipoEgreso> TipoEgresoFromResultSet(ResultSet rs) throws SQLException {
ArrayList<TipoEgreso> tipoEgresoList = new ArrayList<>();
while(rs.next()){
TipoEgreso tipoEgreso = new TipoEgreso();
tipoEgreso.setId(rs.getInt("id"));
tipoEgreso.setNombre(rs.getString("nombre"));
tipoEgresoList.add(tipoEgreso);
}
return tipoEgresoList;
}
} }

View File

@@ -48,13 +48,32 @@
package danielcortes.xyz.models.tipo_egreso; package danielcortes.xyz.models.tipo_egreso;
import danielcortes.xyz.data.ConnectionHolder;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface TipoEgresoDAO { public abstract class TipoEgresoDAO {
List<TipoEgreso> findAll(); protected ConnectionHolder connectionHolder;
List<TipoEgreso> findById(int id);
List<TipoEgreso> findByNombre(String nombre); public abstract List<TipoEgreso> findAll();
boolean insertTipoEgreso(TipoEgreso tipoEgreso); public abstract List<TipoEgreso> findById(int id);
boolean updateTipoEgreso(TipoEgreso tipoEgreso); public abstract List<TipoEgreso> findByNombre(String nombre);
boolean deleteTipoEgreso(TipoEgreso tipoEgreso);
public abstract boolean insertTipoEgreso(TipoEgreso tipoEgreso);
public abstract boolean updateTipoEgreso(TipoEgreso tipoEgreso);
public abstract boolean deleteTipoEgreso(TipoEgreso tipoEgreso);
List<TipoEgreso> tipoEgresoFromResultSet(ResultSet rs) throws SQLException {
ArrayList<TipoEgreso> tipoEgresoList = new ArrayList<>();
while(rs.next()){
TipoEgreso tipoEgreso = new TipoEgreso();
tipoEgreso.setId(rs.getInt("id"));
tipoEgreso.setNombre(rs.getString("nombre"));
tipoEgresoList.add(tipoEgreso);
}
return tipoEgresoList;
}
} }

View File

@@ -33,18 +33,16 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class MysqlTipoIngresoDAO implements TipoIngresoDAO{ public class MysqlTipoIngresoDAO extends TipoIngresoDAO {
private MysqlConnectionHolder mysqlConnection;
public MysqlTipoIngresoDAO(){ public MysqlTipoIngresoDAO(){
this.mysqlConnection = new MysqlConnectionHolder(); this.connectionHolder = new MysqlConnectionHolder();
} }
@Override @Override
public List<TipoIngreso> findAll() { public List<TipoIngreso> findAll() {
List<TipoIngreso> tiposIngresoList = new ArrayList<>(); List<TipoIngreso> tiposIngresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from tipos_ingreso"); PreparedStatement ps = conn.prepareStatement("select * from tipos_ingreso");
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -63,7 +61,7 @@ public class MysqlTipoIngresoDAO implements TipoIngresoDAO{
public List<TipoIngreso> findById(int id) { public List<TipoIngreso> findById(int id) {
List<TipoIngreso> tiposIngresoList = new ArrayList<>(); List<TipoIngreso> tiposIngresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from tipos_ingreso where id = ?"); PreparedStatement ps = conn.prepareStatement("select * from tipos_ingreso where id = ?");
ps.setInt(1,id); ps.setInt(1,id);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -83,7 +81,7 @@ public class MysqlTipoIngresoDAO implements TipoIngresoDAO{
public List<TipoIngreso> findByNombre(String nombre) { public List<TipoIngreso> findByNombre(String nombre) {
List<TipoIngreso> tiposIngresoList = new ArrayList<>(); List<TipoIngreso> tiposIngresoList = new ArrayList<>();
try { try {
Connection conn = mysqlConnection.getConnection(); Connection conn = connectionHolder.getConnection();
PreparedStatement ps = conn.prepareStatement("select * from tipos_ingreso where nombre = ?"); PreparedStatement ps = conn.prepareStatement("select * from tipos_ingreso where nombre = ?");
ps.setString(1,nombre); ps.setString(1,nombre);
ResultSet rs = ps.executeQuery(); ResultSet rs = ps.executeQuery();
@@ -113,16 +111,4 @@ public class MysqlTipoIngresoDAO implements TipoIngresoDAO{
public boolean deleteTipoIngreso(TipoIngreso tipoEgreso) { public boolean deleteTipoIngreso(TipoIngreso tipoEgreso) {
return false; return false;
} }
private List<TipoIngreso> tiposIngresoFromResultSet(ResultSet rs) throws SQLException {
ArrayList<TipoIngreso> tiposIngresoList = new ArrayList<>();
while(rs.next()){
TipoIngreso tipoIngreso = new TipoIngreso();
tipoIngreso.setId(rs.getInt("id"));
tipoIngreso.setNombre(rs.getString("nombre"));
tiposIngresoList.add(tipoIngreso);
}
return tiposIngresoList;
}
} }

View File

@@ -34,9 +34,7 @@ import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
public class SQLiteTipoIngresoDAO implements TipoIngresoDAO{ public class SQLiteTipoIngresoDAO extends TipoIngresoDAO {
private ConnectionHolder connectionHolder;
public SQLiteTipoIngresoDAO(){ public SQLiteTipoIngresoDAO(){
this.connectionHolder = new SQLiteConnectionHolder(); this.connectionHolder = new SQLiteConnectionHolder();
} }
@@ -115,14 +113,4 @@ public class SQLiteTipoIngresoDAO implements TipoIngresoDAO{
return false; return false;
} }
private List<TipoIngreso> tiposIngresoFromResultSet(ResultSet rs) throws SQLException {
ArrayList<TipoIngreso> tiposIngresoList = new ArrayList<>();
while(rs.next()){
TipoIngreso tipoIngreso = new TipoIngreso();
tipoIngreso.setId(rs.getInt("id"));
tipoIngreso.setNombre(rs.getString("nombre"));
tiposIngresoList.add(tipoIngreso);
}
return tiposIngresoList;
}
} }

View File

@@ -24,13 +24,31 @@
package danielcortes.xyz.models.tipo_ingreso; package danielcortes.xyz.models.tipo_ingreso;
import danielcortes.xyz.data.ConnectionHolder;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
public interface TipoIngresoDAO { public abstract class TipoIngresoDAO {
List<TipoIngreso> findAll(); protected ConnectionHolder connectionHolder;
List<TipoIngreso> findById(int id); public abstract List<TipoIngreso> findAll();
List<TipoIngreso> findByNombre(String nombre); public abstract List<TipoIngreso> findById(int id);
boolean insertTipoIngreso(TipoIngreso tipoEgreso); public abstract List<TipoIngreso> findByNombre(String nombre);
boolean updateTipoIngreso(TipoIngreso tipoEgreso);
boolean deleteTipoIngreso(TipoIngreso tipoEgreso); public abstract boolean insertTipoIngreso(TipoIngreso tipoEgreso);
public abstract boolean updateTipoIngreso(TipoIngreso tipoEgreso);
public abstract boolean deleteTipoIngreso(TipoIngreso tipoEgreso);
List<TipoIngreso> tiposIngresoFromResultSet(ResultSet rs) throws SQLException {
ArrayList<TipoIngreso> tiposIngresoList = new ArrayList<>();
while(rs.next()){
TipoIngreso tipoIngreso = new TipoIngreso();
tipoIngreso.setId(rs.getInt("id"));
tipoIngreso.setNombre(rs.getString("nombre"));
tiposIngresoList.add(tipoIngreso);
}
return tiposIngresoList;
}
} }