sábado, 19 de abril de 2014

Continuación con la conexión a la base de datos

Creador del Post: Javier Gómez Madrigal
Hora Inicio: 15:00 Hora Fin: 18:00
Horas Trabajadas: 3

Se realizó la conexión de 2 procedures más, la consulta de movimientos y la bajada de una canción.

 public DataSet consultaMovimientos(String pMiembro)
        {
            try
            {
                conection.Open();
                procedure = new SqlCommand("CONSULTA_MOVCANCXMIEMBRO", conection);
                procedure.CommandType = CommandType.StoredProcedure;
                adapter = new SqlDataAdapter();
                procedure.Parameters.Add("@MIEMBRO", SqlDbType.VarChar, 50, "@MIEMBRO");
                procedure.Parameters["@MIEMBRO"].Value = pMiembro;
                adapter.SelectCommand = procedure;
                procedure.Parameters.Add("@RETURN_VALUE", SqlDbType.Int).Direction = ParameterDirection.ReturnValue;
                procedure.ExecuteNonQuery();
                int cod = (int)procedure.Parameters["@RETURN_VALUE"].Value;
                conection.Close();
                if (cod > 0)
                {
                    data = new DataSet();
                    adapter.Fill(data);
                    return data;
                }
                else
                {
                    return null;
                }
            }
            catch (Exception)
            {
                conection.Close();
                return null;
            }
        }

        public int bajadaCancion(int pID, String pIP, String pPostBy, String pPostIn)
        {
            try
            {
                conection.Open();
                procedure = new SqlCommand("BAJADA_CANCION", conection);
                procedure.CommandType = CommandType.StoredProcedure;
                procedure.Parameters.Add("@ID_MOVCANCION", SqlDbType.Int);
                procedure.Parameters["@ID_MOVCANCION"].Value = pID;
                procedure.Parameters.Add("@IP", SqlDbType.VarChar, 50, "@IP");
                procedure.Parameters["@IP"].Value = pIP;
                procedure.Parameters.Add("@POST_BY", SqlDbType.VarChar, 30, "@POST_BY");
                procedure.Parameters["@POST_BY"].Value = pPostBy;
                procedure.Parameters.Add("@POST_IN", SqlDbType.VarChar, 30, "@POST_IN");
                procedure.Parameters["@POST_IN"].Value = pPostIn;
                procedure.Parameters.Add("@RETURN_VALUE", SqlDbType.Int).Direction = ParameterDirection.ReturnValue;
                procedure.ExecuteNonQuery();
                int cod = (int)procedure.Parameters["@RETURN_VALUE"].Value;
                conection.Close();
                if (cod > 0)
                {
                    return 1;
                }
                else
                {
                    return -1;
                }
            }
            catch (Exception)
            {
                conection.Close();
                return -1;
            }
        }

No hay comentarios.:

Publicar un comentario