diff --git a/Code/LinqToPgSQL/PersLinqToPgSQL.cs b/Code/LinqToPgSQL/PersLinqToPgSQL.cs index ccaad1d..17ba8e1 100644 --- a/Code/LinqToPgSQL/PersLinqToPgSQL.cs +++ b/Code/LinqToPgSQL/PersLinqToPgSQL.cs @@ -1,37 +1,38 @@ -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; -using Npgsql; -using Model; -using System.IO; - -namespace LinqToPgSQL -{ - public class PersLinqToPgSQL : IPersistanceManager - { - private static string Host = "90.114.135.116"; - private static string User = "postgres"; - private static string DBname = "conseco"; - private static string Password = "lulu"; - private static string Port = "5432"; - - string connString = - String.Format( - "Server={0};Username={1};Database={2};Port={3};Password={4};SSLMode=Prefer", - Host, - User, - DBname, - Port, - Password); - - public PersLinqToPgSQL() { } - public IEnumerable LoadInscrit() - { - List ListeInscrits = new List(); - - var conn = new NpgsqlConnection(connString); +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using Npgsql; +using Model; +using System.IO; +using System.Diagnostics; + +namespace LinqToPgSQL +{ + public class PersLinqToPgSQL : IPersistanceManager + { + private static string Host = "90.114.135.116"; + private static string User = "postgres"; + private static string DBname = "conseco"; + private static string Password = "lulu"; + private static string Port = "5432"; + + string connString = + String.Format( + "Server={0};Username={1};Database={2};Port={3};Password={4};SSLMode=Prefer", + Host, + User, + DBname, + Port, + Password); + + public PersLinqToPgSQL() { } + public IEnumerable LoadInscrit() + { + List ListeInscrits = new List(); + + var conn = new NpgsqlConnection(connString); Console.Out.WriteLine("Ouverture de la connection"); try { conn.Open(); @@ -41,65 +42,54 @@ namespace LinqToPgSQL conn.Close(); Environment.Exit(0); - } - - - var AllInscrit = new NpgsqlCommand("SELECT * FROM Inscrit", conn); - - var reader = AllInscrit.ExecuteReader(); - while (reader.Read()) - { - Console.WriteLine( - string.Format( - "({0}, {1}, {2}, {3}, {4}", - reader.GetString(0), - reader.GetString(1), - reader.GetString(2), - reader.GetString(3), - reader.GetString(4) - /*reader.GetInt32(2).ToString()*/ - ) - ); - foreach (var EltInscrit in reader) - { - ListeInscrits.Add(new(reader.GetString(0), reader.GetString(1), reader.GetString(3), reader.GetString(2), reader.GetString(4))); - } - - - } - reader.Close(); - - return ListeInscrits; - } - - - /*Revoir la BDD, probleme de clé étrangère de devise*/ - public async void SupprimerInscritBdd(Inscrit i) - { - /*List ListeInscrits = new List(LoadInscrit());*/ - - var conn = new NpgsqlConnection(connString); - Console.Out.WriteLine("Ouverture de la connection"); - conn.Open(); - - - string requete = $"DELETE FROM INSCRIT WHERE id=(@p)"; - string requeteFKey = $"DELETE FROM DEVISEINSCRIT WHERE idInscrit=(@p2)"; - - using (var command1 = new NpgsqlCommand(requeteFKey, conn)) - { - command1.Parameters.AddWithValue("p2", i.Id); - await command1.ExecuteNonQueryAsync(); - } - - using (var command = new NpgsqlCommand(requete, conn)) - { - command.Parameters.AddWithValue("p", i.Id); - await command.ExecuteNonQueryAsync(); - } - - - - } - } -} + } + + + + + + + NpgsqlDataReader dbReader = new NpgsqlCommand("SELECT * FROM Inscrit", conn).ExecuteReader(); + + while (dbReader.Read()) + { + + ListeInscrits.Add(new Inscrit(dbReader.GetString(0), dbReader.GetString(1), dbReader.GetString(2), dbReader.GetString(3), dbReader.GetString(4))); + } + + dbReader.Close(); + + return ListeInscrits; + } + + + /*Revoir la BDD, probleme de clé étrangère de devise*/ + public async void SupprimerInscritBdd(Inscrit i) + { + /*List ListeInscrits = new List(LoadInscrit());*/ + + var conn = new NpgsqlConnection(connString); + Console.Out.WriteLine("Ouverture de la connection"); + conn.Open(); + + + string requete = $"DELETE FROM INSCRIT WHERE id=(@p)"; + string requeteFKey = $"DELETE FROM DEVISEINSCRIT WHERE idInscrit=(@p2)"; + + using (var command1 = new NpgsqlCommand(requeteFKey, conn)) + { + command1.Parameters.AddWithValue("p2", i.Id); + await command1.ExecuteNonQueryAsync(); + } + + using (var command = new NpgsqlCommand(requete, conn)) + { + command.Parameters.AddWithValue("p", i.Id); + await command.ExecuteNonQueryAsync(); + } + + + + } + } +}