Fusion de Link_toPgsql dans Code
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/push Build is passing
Details
Hug0lvt
2 years ago
commit
17301c5ee9
@ -0,0 +1,17 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net6.0-windows</TargetFramework>
|
||||
<Nullable>enable</Nullable>
|
||||
<UseWPF>true</UseWPF>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Npgsql" Version="6.0.7" />
|
||||
</ItemGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<ProjectReference Include="..\Model\Model.csproj" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
@ -0,0 +1,207 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using System.Data;
|
||||
using System.Configuration;
|
||||
using Npgsql;
|
||||
using Model;
|
||||
using System.IO;
|
||||
using System.Diagnostics;
|
||||
using System.Windows;
|
||||
using System.Threading;
|
||||
|
||||
namespace LinqToPgSQL
|
||||
{
|
||||
public class PersLinqToPgSQL : IPersistanceManager
|
||||
{
|
||||
string connexionBDD = String.Format("Server=90.114.135.116; Username=postgres; Database=conseco; Port=5432; Password=lulu; SSLMode=Prefer");
|
||||
|
||||
public string LoadInscrit(string id, string mdp)
|
||||
{
|
||||
string resultat="";
|
||||
var conn = new NpgsqlConnection(connexionBDD);
|
||||
Console.Out.WriteLine("Ouverture de la connection");
|
||||
conn.Open();
|
||||
NpgsqlParameter p1 = new NpgsqlParameter { ParameterName = "p", Value = id };
|
||||
NpgsqlParameter p2 = new NpgsqlParameter { ParameterName = "p2", Value = mdp };
|
||||
NpgsqlCommand cmd = new NpgsqlCommand($"SELECT id FROM INSCRIT WHERE (nom=(@p) OR mail=(@p)) AND mdp=@p2", conn);
|
||||
cmd.Parameters.Add(p1);
|
||||
cmd.Parameters.Add(p2);
|
||||
NpgsqlDataReader dr = cmd.ExecuteReader();
|
||||
try
|
||||
{
|
||||
dr.Read();
|
||||
resultat = dr.GetString(0);
|
||||
dr.Close();
|
||||
return resultat;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
MessageBox.Show(ex+"Utilisateur inconnu");
|
||||
dr.Close();
|
||||
return "null";//a changer doit retester
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public IEnumerable<Banque> LoadBanque()
|
||||
{
|
||||
List<Banque> ListeBanques = new List<Banque>();
|
||||
|
||||
var conn = new NpgsqlConnection(connexionBDD);
|
||||
Console.Out.WriteLine("Ouverture de la connection");
|
||||
try
|
||||
{
|
||||
conn.Open();
|
||||
}
|
||||
catch
|
||||
{
|
||||
conn.Close();
|
||||
MessageBox.Show("Problème de connection à la base de donnée. Aprés fermeture, l'application se fermera automatiquement");
|
||||
Environment.Exit(-1);
|
||||
|
||||
}
|
||||
|
||||
|
||||
NpgsqlDataReader dbReader = new NpgsqlCommand("SELECT * FROM Banque", conn).ExecuteReader();
|
||||
|
||||
while (dbReader.Read())
|
||||
{
|
||||
|
||||
ListeBanques.Add(new Banque(dbReader.GetString(0), dbReader.GetString(1), dbReader.GetString(2)));
|
||||
|
||||
}
|
||||
|
||||
|
||||
dbReader.Close();
|
||||
|
||||
|
||||
return ListeBanques;
|
||||
}
|
||||
|
||||
/*Charge le compte d'un inscrit*/
|
||||
public IEnumerable<Compte> LoadCompte(Inscrit i)
|
||||
{
|
||||
List<Compte> ListeCompte = new List<Compte>();
|
||||
|
||||
var conn = new NpgsqlConnection(connexionBDD);
|
||||
Console.Out.WriteLine("Ouverture de la connection");
|
||||
try
|
||||
{
|
||||
conn.Open();
|
||||
}
|
||||
catch
|
||||
{
|
||||
conn.Close();
|
||||
MessageBox.Show("Problème de connection à la base de données. Aprés fermeture, l'application se fermera automatiquement.");
|
||||
Environment.Exit(-1);
|
||||
}
|
||||
|
||||
string requete = "Select * FROM Compte c, InscrBanque ib, Inscrit i WHERE c.idInscrit = ib.idInscrit AND c.idInscritBanque = ib.id AND i.id = (@p1)";
|
||||
NpgsqlDataReader dbReader = new NpgsqlCommand("Select * FROM Compte c, InscrBanque ib, Inscrit i WHERE c.idInscrit = ib.idInscrit AND c.idInscritBanque = ib.id AND i.id = (@p1) ", conn).ExecuteReader();
|
||||
|
||||
using (var command1 = new NpgsqlCommand(requete, conn))
|
||||
{
|
||||
command1.Parameters.AddWithValue("p", i.Id);
|
||||
/*await command1.ExecuteNonQueryAsync();*/
|
||||
}
|
||||
|
||||
|
||||
while (dbReader.Read())
|
||||
{
|
||||
ListeCompte.Add(new Compte(dbReader.GetString(0), dbReader.GetInt64(1)));
|
||||
}
|
||||
dbReader.Close();
|
||||
return ListeCompte;
|
||||
}
|
||||
|
||||
/*Suppression d'un inscrit dans la base de données*/
|
||||
public async void SupprimerInscritBdd(Inscrit i)
|
||||
{
|
||||
/*List<Inscrit> ListeInscrits = new List<Inscrit>(LoadInscrit());*/
|
||||
|
||||
var conn = new NpgsqlConnection(connexionBDD);
|
||||
Console.Out.WriteLine("Ouverture de la connection");
|
||||
try
|
||||
{
|
||||
conn.Open();
|
||||
}
|
||||
catch
|
||||
{
|
||||
conn.Close();
|
||||
MessageBox.Show("Problème de connection à la base de données. Aprés fermeture, l'application se fermera automatiquement.");
|
||||
Environment.Exit(-1);
|
||||
}
|
||||
|
||||
|
||||
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("p", i.Id);
|
||||
await command1.ExecuteNonQueryAsync();
|
||||
}
|
||||
|
||||
|
||||
SupprimerToutesBanquesBdd(i);
|
||||
/* SupprimerCompteBdd(i);
|
||||
SupprimerEcheancierBdd(i);
|
||||
SupprimerPlanificationBdd(i);
|
||||
*/
|
||||
}
|
||||
|
||||
/* Suppression de toutes les banques d'un inscrit*/
|
||||
public async void SupprimerToutesBanquesBdd(Inscrit i)
|
||||
{
|
||||
var conn = new NpgsqlConnection(connexionBDD);
|
||||
Console.Out.WriteLine("Ouverture de la connection");
|
||||
try
|
||||
{
|
||||
conn.Open();
|
||||
}
|
||||
catch
|
||||
{
|
||||
conn.Close();
|
||||
MessageBox.Show("Problème de connection ave la base de données. Aprés fermeture de la fenêtre, l'application se fermera automatiquement");
|
||||
Environment.Exit(-1);
|
||||
}
|
||||
string requete = $"DELETE * FROM BANQUE b, INSCRBANQUE ib WHERE b.nom=ib.nomBanque AND ib.idInscrit=(@id)";
|
||||
using (var command1 = new NpgsqlCommand(requete, conn))
|
||||
{
|
||||
command1.Parameters.AddWithValue("p", i.Id);
|
||||
await command1.ExecuteNonQueryAsync();
|
||||
}
|
||||
}
|
||||
|
||||
/*Suppression d'une banque d'un inscrit*/
|
||||
public async void SupprimerBanqueBdd(Inscrit i, Banque b)
|
||||
{
|
||||
var conn = new NpgsqlConnection(connexionBDD);
|
||||
Console.Out.WriteLine("Ouverture de la connection");
|
||||
try
|
||||
{
|
||||
conn.Open();
|
||||
}
|
||||
catch
|
||||
{
|
||||
conn.Close();
|
||||
MessageBox.Show("Problème de connection avec la base de données. Aprés fermeture de la fenêtre, l'application se fermera automatiquement");
|
||||
Environment.Exit(-1);
|
||||
}
|
||||
|
||||
await using var cmd = new NpgsqlCommand("DELETE FROM InscrBanque WHERE nombanque=(@b) AND idinscrit=(@i)", conn)
|
||||
{
|
||||
Parameters =
|
||||
{
|
||||
new("b", b.Nom),
|
||||
new("i", i.Id)
|
||||
}
|
||||
};
|
||||
await cmd.ExecuteNonQueryAsync();
|
||||
|
||||
// attente des autres supression
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,6 @@
|
||||
[.ShellClassInfo]
|
||||
IconResource=C:\WINDOWS\System32\SHELL32.dll,294
|
||||
[ViewState]
|
||||
Mode=
|
||||
Vid=
|
||||
FolderType=Generic
|
||||
Loading…
Reference in new issue