Home > ASP.NET, Postgresql - SQL > Asp.Net e postgresql accesso ai dati

Asp.Net e postgresql accesso ai dati

Esempi di query contro database postgresql in Asp.Net linguaggio C#

Asp.net aprire e chiudere una Connessione verso un database postresql in c#

        
  public static void Open()
  {
     string NpgsqlConnectionString =
     "Server=10.0.1.150;Port=5432;" + "Database=eth2010uk;" + 
     "User ID=postgres;" + "Password=12345678;" +
     "Encoding=unicode;" + "Pooling=false;" + "ConnectionLifeTime=10";
     dbcon = new NpgsqlConnection(NpgsqlConnectionString);
     dbcon.Open();
           ... 
           ...
     dbcon.Close();  
  }

Eseguire una query che ritorna un DataSet verso un database postgresql in Asp.net in C#

public static DataSet mySqlQuery(string  _sqlquery )
   {
     //  esempio di query sql:
     //  _sqlquery = "SELECT * FROM library" ; 
     dbcon = new NpgsqlConnection(NpgsqlConnectionString);     
     NpgsqlDataAdapter myDataAdapter = new NpgsqlDataAdapter(_sqlquery, dbcon);
     DataSet ds = new DataSet();
     myDataAdapter.Fill(ds);
     return ds;
   }

asp.net eseguire una query di tipo INSERT, DELETE, UPDATE contro un database postgresql metodo ExecuteNonQuery c#
ExecuteNonQuery ritorna il numero ( System.int32 )  di records modificati/interessati.

   public static void _sqlqueryrun(string _SqlQuery)
   {
        // esempi _SQlQuery
        // "DELETE FROM pruducts WHERE itemid= 100""
        dbcon = new NpgsqlConnection(NpgsqlConnectionString);
        NpgsqlCommand command = new NpgsqlCommand(_SqlQuery, dbcon);
        command.dbcon.Open() ;
        int n_righe = command.ExecuteNonQuery();
        dbcon.Close();
   }

asp.net eseguire una query di tipo INSERT, DELETE, UPDATE contro un database postgresql metodo ExecuteReader c#

   public static void _sqlqueryrun(string _SqlQuery)
   {
        // esempi _SQlQuery
        //    "DELETE FROM pruducts WHERE itemid= 100""
        dbcon = new NpgsqlConnection(NpgsqlConnectionString);
        NpgsqlCommand command = new NpgsqlCommand(_SqlQuery, dbcon);
        reader = command.ExecuteReader();
        reader.Close();
   }

asp.net lanciare una query verso un database postgresql che ritorna un DataReader

public static NpgsqlDataReader _QueryRunNDR(string _SqlQuery, NpgsqlConnection dbcon)
   {              
      NpgsqlCommand myCommand = new NpgsqlCommand(_SqlQuery, dbcon);      
      NpgsqlDataReader result = myCommand.ExecuteReader();
      return result; 
   }

        ....        

        _query = "SELECT * FROM library" ;
        NpgsqlDataAdapter myDataAdapter = new NpgsqlDataAdapter(_query,  myConnection);
        DataSet ds_a = new DataSet();
        myDataAdapter.Fill(ds_a, "Library");

        DataList2.DataSource = ds_a;
        DataList2.DataBind();

        myConnection.Close();
        ...

.ExecuteNonQuery

    protected string mySqlNonQueryRun(string mySqlQuery)
    {
        string NpgsqlConnectionString =
            "Server=10.0.1.125;Port=5432;" + "Database=" + myDB.Text + ";" +
            "User ID=postgres;" + "Password=12345678;" +
            "Encoding=unicode;" + "Pooling=false;" + "ConnectionLifeTime=10";
        NpgsqlConnection dbcon = new NpgsqlConnection(NpgsqlConnectionString);

        dbcon.Open();
        NpgsqlCommand mycommand = new NpgsqlCommand(mySqlQuery, dbcon);
        int numrighe = mycommand.ExecuteNonQuery(); //  .ExecuteReader();

        dbcon.Close();
        // CSMJavaS( "Update rows n.: " + numrighe.ToString() );
        return ("Update rows n.: " + numrighe.ToString());

    }

Asp.net query di tipo delete su database postgresql c#

public static void DeleteProducts(String id, String NpgsqlConnectionString)
{
    dbcon = new NpgsqlConnection(NpgsqlConnectionString);   
    NpgsqlCommand _command = new NpgsqlCommand("DELETE FROM products WHERE itemid= :id", dbcon);
    _command.Parameters.Add(new NpgsqlParameter("id", DbType.Int32));
    _command.Parameters[0].Value = id;
    _command.ExecuteScalar();

    dbcon.Open();
    //HACK: ExecuteScalar should be myCommand.ExecuteNonQuery();
    _command.ExecuteScalar();
    dbcon.Close();

    // reader = command.ExecuteReader();
}

Stored Procedure

Asp.Net C#: Query di Login verso database postgresql per controllare e confermare la presenza di un’email usando una stored procedure, la UserLogin(character varying, charachter varying),



public String Login(String email, String password,  String NpgsqlConnectionString)
{
    // creare istanza di Connessione e Oggetto Command 
    NpgsqlConnection myConnection = new NpgsqlConnection(NpgsqlConnectionString);   
    NpgsqlCommand _Command = new NpgsqlCommand("UserLogin(:Email,:Password)", myConnection);

    // marcare il comando come SPROC stored procedure
    _Command.CommandType = CommandType.StoredProcedure;

    // Aggiungere Parametri usando  Parameters[x]  
    _Command.Parameters.Add(new NpgsqlParameter("Email", DbType.String));
    _Command.Parameters[0].Value = email;
    _Command.Parameters.Add(new NpgsqlParameter("Password", DbType.String));
    _Command.Parameters[1].Value = password;   

    // Aprire le connessione al database ed eseguire il commando
    myConnection.Open();
    Object userName = (Object)myCommand.ExecuteScalar();
    myConnection.Close();

    if ((userName != null) && (!DBNull.Value.Equals(userName)))
    {
       return ((string)userName).Trim();
    }

    return String.Empty;
}

Asp.Net C#: Query verso database postgresql per ottenere un DataReader usando una stored procedure, la GetSingleDocument(integer ),



public NpgsqlDataReader GetSingleDocument(int itemid) {

   // creare istanza di Connessione e Oggetto Command 
  NpgsqlConnection myConnection = new    NpgsqlConnection(ConfigurationManager.AppSettings["NpgsqlConnectionString"]);
  NpgsqlCommand myCommand = new NpgsqlCommand("GetSingleDocument(:ItemID)", myConnection);

  // marcare il comando come SPROC (stored procedure)
  myCommand.CommandType = CommandType.StoredProcedure;

  // Aggiungere Parametri alla Stored Procedure  
  NpgsqlParameter parameterItemId = new NpgsqlParameter("ItemID", DbType.Int32);
  parameterItemId.Value = itemid;
  myCommand.Parameters.Add(parameterItemId);

  // Eseguire il commando 
  // Il  parametro opzionale CommandBehavior.CloseConnection permette di chiudere la connessione una volta 
  // chiuso il datareader 
  myConnection.Open(); 
  NpgsqlDataReader result = myCommand.ExecuteReader(CommandBehavior.CloseConnection);
  //  myConnection.Close();  // non è più necessario

  // ritornare il datareader
  return result;

}

Query verso database postgresql per ottenere il primo record di un DataReader usando il parametro Command.SingleResult del command.ExecuteReader e una stored procedure la GetSingleDocument(integer),

public NpgsqlDataReader GetSingleDocument(int itemid) {

   // creare istanza di Connessione e Oggetto Command 
  NpgsqlConnection myConnection = new    NpgsqlConnection(ConfigurationManager.AppSettings["NpgsqlConnectionString"]);
  NpgsqlCommand myCommand = new NpgsqlCommand("GetSingleDocument(:ItemID)", myConnection);

  // marcare il comando come SPROC (stored procedure)
  myCommand.CommandType = CommandType.StoredProcedure;

  // Aggiungere Parametri alla Stored Procedure  
  NpgsqlParameter parameterItemId = new NpgsqlParameter("ItemID", DbType.Int32);
  parameterItemId.Value = itemid;
  myCommand.Parameters.Add(parameterItemId);

  // Eseguire il commando 
  // Parametri opzionali
  // CommandBehavior.SingleResult ritorna il primo record
  // CommandBehavior.CloseConnection chiuso il datareader chiude la connessione

   myConnection.Open(); 
   NpgsqlDataReader result = myCommand.ExecuteReader(CommandBehavior.SingleResult | CommandBehavior.CloseConnection);

  // ritornare il datareader
  return result;

}

Asp.net query di tipo update su database postgresql c#

 public static void _UpdateProducts(String Prd_id, String Quantita)
    {
     NpgsqlCommand command = new NpgsqlCommand("UPDATE products SET quantita= :quantita WHERE itemid= :prd_id;", dbcon);
    command.Parameters.Add(new NpgsqlParameter("prd_id", DbType.Int32));
    command.Parameters.Add(new NpgsqlParameter("quantita", DbType.Double));
    command.Parameters[0].Value = Prd_id;
    command.Parameters[1].Value = Quantita;
    reader = command.ExecuteReader();
    reader.Close();
    }

Risorse:

Annunci
  1. Non c'è ancora nessun commento.
  1. No trackbacks yet.

Rispondi

Inserisci i tuoi dati qui sotto o clicca su un'icona per effettuare l'accesso:

Logo WordPress.com

Stai commentando usando il tuo account WordPress.com. Chiudi sessione / Modifica )

Foto Twitter

Stai commentando usando il tuo account Twitter. Chiudi sessione / Modifica )

Foto di Facebook

Stai commentando usando il tuo account Facebook. Chiudi sessione / Modifica )

Google+ photo

Stai commentando usando il tuo account Google+. Chiudi sessione / Modifica )

Connessione a %s...

%d blogger hanno fatto clic su Mi Piace per questo: