Lab6DS4/ConexionBaseDeDatos.cs at main · alosslessdev/Lab6DS4 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

/*
 * Carrasco, Nathan
 * Herrera, Francisco
 * Wu, Iván
 */

namespace Lab_6
{
    internal class ConexionBaseDeDatos
    {

        private string detallesConexion = "Data Source=localhost;Initial Catalog=Libreria;Integrated Security=True";

        internal DataSet ObtenerDatos(bool entradaSiOrdenarPorNuevoPrimero)
        {
            DataSet datos = new DataSet();
            try
            {
                using (SqlConnection conexion = new SqlConnection(detallesConexion))
                {
                    if (entradaSiOrdenarPorNuevoPrimero)
                    {
                        string query = "SELECT ID, Titulo, Autor, CantidadDisponible FROM Libros ORDER BY ID Desc";
                        SqlDataAdapter adaptador = new SqlDataAdapter(query, conexion);
                        adaptador.Fill(datos, "Libros");
                    }
                    else
                    {

                        string query = "SELECT ID, Titulo, Autor, CantidadDisponible FROM Libros";
                        SqlDataAdapter adaptador = new SqlDataAdapter(query, conexion);
                        adaptador.Fill(datos, "Libros");
                    }
                }
            }
            catch (SqlException ex)
            {
                throw new Exception("Error al obtener libros: " + ex.Message);
            }
            return datos;
        }

        internal void InsertDatos(string tituloMetodo, string salario, int cantidadDisponibleMetodo)
        {
            try
            {
                using (SqlConnection conexion = new SqlConnection(detallesConexion))
                {
                    string query = "INSERT INTO Libros(Titulo, Autor, CantidadDisponible) VALUES (@Titulo, @Autor, @CantidadDisponible)";
                    SqlCommand instruccion = new SqlCommand(query, conexion);
                    instruccion.Parameters.AddWithValue("@Titulo", tituloMetodo);
                    instruccion.Parameters.AddWithValue("@Autor", salario);
                    instruccion.Parameters.AddWithValue("@CantidadDisponible", cantidadDisponibleMetodo);
                    conexion.Open();
                    instruccion.ExecuteNonQuery();
                }
            }
            catch (SqlException ex)
            {
                throw new Exception("Error al insertar libros: " + ex.Message);
            }

        }

        internal void UpdateDatos(int cantidadDisponibleMetodo, int idEntrada)
        {
            try
            {
                using (SqlConnection conexion = new SqlConnection(detallesConexion))
                {
                    string query = "UPDATE Libros SET CantidadDisponible = @CantidadDisponible WHERE id = @id";
                    SqlCommand instruccion = new SqlCommand(query, conexion);
                    instruccion.Parameters.AddWithValue("@CantidadDisponible", cantidadDisponibleMetodo);
                    instruccion.Parameters.AddWithValue("@id", idEntrada);

                    conexion.Open();
                    instruccion.ExecuteNonQuery();
                }
            }
            catch (SqlException ex)
            {
                throw new Exception("Error al insertar libros: " + ex.Message);
            }

        }

        internal void DeleteDatos(string queryEntrada)
        {
            try
            {
                using (SqlConnection conexion = new SqlConnection(detallesConexion))
                {
                    string query = queryEntrada;
                    SqlCommand instruccion = new SqlCommand(query, conexion);
                    conexion.Open();
                    instruccion.ExecuteNonQuery();
                }
            }
            catch (SqlException ex)
            {
                throw new Exception("Error al insertar libros: " + ex.Message);
            }

        }

    }


}