Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public List<Producto> PorCodigo(string codigo)
- {
- MySqlConnectionStringBuilder builder = this.StringConexion();
- List<Producto> productos = new List<Producto>();
- using (MySqlConnection conexion = new MySqlConnection(builder.ToString()))
- {
- try
- {
- conexion.Open();
- string sqlConsultaCodigo = "SELECT * FROM producto WHERE CodProducto = @CodProducto";
- MySqlCommand cmdConsultaCodigo = new MySqlCommand(sqlConsultaCodigo, conexion);
- cmdConsultaCodigo.Parameters.AddWithValue("@CodProducto", codigo);
- MySqlDataReader lector = cmdConsultaCodigo.ExecuteReader();
- while (lector.Read())
- {
- Producto producto = new Producto(lector.GetString(0), lector.GetString(1), lector.GetString(2), lector.GetInt32(3), lector.GetDecimal(4), lector.GetInt32(5), lector.GetInt32(6), lector.GetInt32(7));
- productos.Add(producto);
- }
- }
- catch (Exception e)
- {
- this.guardarMensajeError(e);
- return null;
- }
- }
- return productos;
- }
- public List<Producto> PorMarca(string marca)
- {
- MySqlConnectionStringBuilder builder = this.StringConexion();
- List<Producto> productos = new List<Producto>();
- using (MySqlConnection conexion = new MySqlConnection(builder.ToString()))
- {
- try
- {
- conexion.Open();
- string sqlConsultaMarca = "SELECT * FROM producto WHERE IdMarca = @IdMarca";
- MySqlCommand cmdConsultaMarca = new MySqlCommand(sqlConsultaMarca, conexion);
- cmdConsultaMarca.Parameters.AddWithValue("@IdMarca", marca);
- MySqlDataReader lector = cmdConsultaMarca.ExecuteReader();
- while (lector.Read())
- {
- Producto producto = new Producto(lector.GetString(0), lector.GetString(1), lector.GetString(2), lector.GetInt32(3), lector.GetDecimal(4), lector.GetInt32(5), lector.GetInt32(6), lector.GetInt32(7));
- productos.Add(producto);
- }
- }
- catch (Exception e)
- {
- this.guardarMensajeError(e);
- return null;
- }
- }
- return productos;
- }
- public List<Producto> PorEstanteria(string estanteria)
- {
- MySqlConnectionStringBuilder builder = this.StringConexion();
- List<Producto> productos = new List<Producto>();
- List<string> codigosProducto = new List<string>();
- using (MySqlConnection conexion = new MySqlConnection(builder.ToString()))
- {
- try
- {
- conexion.Open();
- string sqlConsultaEstanteria = "SELECT CodProducto FROM producto-estante WHERE IdEstanteria = @IdEstanteria";
- MySqlCommand cmdConsultaEstanteria = new MySqlCommand(sqlConsultaEstanteria, conexion);
- cmdConsultaEstanteria.Parameters.AddWithValue("@IdEstanteria", estanteria);
- MySqlDataReader lector = cmdConsultaEstanteria.ExecuteReader();
- while (lector.Read())
- {
- codigosProducto.Add(lector.GetString(0));
- }
- lector.Close();
- foreach (string s in codigosProducto)
- {
- string sqlConsultaEstanteriaProducto = "SELECT * FROM producto WHERE CodProducto = @CodProducto";
- MySqlCommand cmdConsultaEstanteriaProducto = new MySqlCommand(sqlConsultaEstanteriaProducto, conexion);
- cmdConsultaEstanteriaProducto.Parameters.AddWithValue("@CodProducto", s);
- MySqlDataReader lectorProdcuto = cmdConsultaEstanteriaProducto.ExecuteReader();
- while (lector.Read())
- {
- Producto producto = new Producto(lector.GetString(0), lector.GetString(1), lector.GetString(2), lector.GetInt32(3), lector.GetDecimal(4), lector.GetInt32(5), lector.GetInt32(6), lector.GetInt32(7));
- productos.Add(producto);
- }
- }
- }
- catch (Exception e)
- {
- this.guardarMensajeError(e);
- return null;
- }
- }
- return productos;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement