TRANSACTIONS ORACLE SQL SERVER CSV AVEC C#

using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Windows.Forms;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data.OracleClient;
using System.IO;

namespace ProjetIGL
{
    /// <summary>
    /// Classe oracle connexion déconnexion extraire loder
    /// </summary>

    /// <summary>
    /// Classe oracle connexion déconnexion extraire loder
    /// </summary>

    public class OracleConnect
    {


        public DataTable SourceDestOracle = new DataTable();

        ///Methode connecter oracle
        public OracleConnection ConnectOracle(string serveurOracle, int port, string UserOracle, string PasswordOracle)
        {
            System.Data.OracleClient.OracleConnection OraCon = new OracleConnection();
            string conString;/// chemin de connexion oracle
            conString = "Data Source=" + serveurOracle + ":" + port + ";User Id=" + UserOracle + ";Password=" + PasswordOracle + ";";
            OraCon.ConnectionString = conString;
            try
            {
                OraCon.Open();
                MessageBox.Show("Connexion ORACLE effectuée avec succé");
                return OraCon;
            }
            catch (Exception e)
            {
                MessageBox.Show("Impossible de connecter Oracle " + e);
                return OraCon;
            }
        }///fin Connect



        /// Methode Déconnexion Oracle

        public bool DisconnectOracle(OracleConnection OraCon)
        {
            try
            {
                OraCon.Close();
                MessageBox.Show("Déconnnexion ORACLE effectuée avec succé");
                return false;
            }
            catch (Exception e)
            {
                MessageBox.Show("Impossible de déconnecter Oracle " + e);
                return false;
            }


        }///Fin disconnect



        ///Extraire les données
        public DataTable ExtractOracle(string Requete, OracleConnection Cn)
        {
            int i = 0;
            DataRow Tableau;
            OracleDataReader DSResultat;



            DataTable SourceDestOracle = new DataTable("Test");
            ///Définition des colonnes nécessaires
            System.Data.DataColumn ColID;
            System.Data.DataColumn ColNOM;
            System.Data.DataColumn ColPRENOM;
            System.Data.DataColumn ColSEXE;
            System.Data.DataColumn ColAGE;
            System.Data.DataColumn ColVILLE;

            ColID = new DataColumn();
            ColNOM = new DataColumn();
            ColPRENOM = new DataColumn();
            ColSEXE = new DataColumn();
            ColAGE = new DataColumn();
            ColVILLE = new DataColumn();

            try
            {
                ///Création des colonnes dans le Data Table
                ColID.DataType = System.Type.GetType("System.Int32");
                ColID.ColumnName = "IDCLIENT";
                SourceDestOracle.Columns.Add(ColID);

                ColNOM.DataType = System.Type.GetType("System.String");
                ColNOM.ColumnName = "NOM";
                SourceDestOracle.Columns.Add(ColNOM);

                ColPRENOM.DataType = System.Type.GetType("System.String");
                ColPRENOM.ColumnName = "PRENOM";
                SourceDestOracle.Columns.Add(ColPRENOM);

                ColSEXE.DataType = System.Type.GetType("System.String");
                ColSEXE.ColumnName = "SEXE";
                SourceDestOracle.Columns.Add(ColSEXE);

                ColAGE.DataType = System.Type.GetType("System.Int32");
                ColAGE.ColumnName = "AGE";
                SourceDestOracle.Columns.Add(ColAGE);

                ColVILLE.DataType = System.Type.GetType("System.String");
                ColVILLE.ColumnName = "VILLE";
                SourceDestOracle.Columns.Add(ColVILLE);


            }
            catch (Exception e)
            {
                MessageBox.Show("Impossible d'extraire à partir d'oracle " + e);
            }
            try
            {
                DateTime TempsExtractORACLE = DateTime.Now;
                OracleCommand Cmd = new OracleCommand(Requete, Cn);

                DSResultat = Cmd.ExecuteReader();

                while (DSResultat.Read())
                {
                    Tableau = SourceDestOracle.NewRow();

                    Tableau["IDCLIENT"] = DSResultat.GetInt32(5);
                    Tableau["NOM"] = DSResultat.GetString(0);
                    Tableau["PRENOM"] = DSResultat.GetString(1);
                    Tableau["SEXE"] = DSResultat.GetString(2);
                    Tableau["AGE"] = DSResultat.GetInt32(3);
                    Tableau["VILLE"] = DSResultat.GetString(4);
                    SourceDestOracle.Rows.Add(Tableau);
                    i++;
                }

                TimeSpan TempsEcoule = DateTime.Now.Subtract(TempsExtractORACLE);
                MessageBox.Show("Extraction Oracle Effectuée avec succé     \n Le temps d'extraction de données est : " + TempsEcoule.TotalMilliseconds.ToString() + " Mellisecondes");
                DSResultat.Close();
                return SourceDestOracle;
            }
            catch (Exception e)
            {
                MessageBox.Show("Extraction ORACLE impossible " + e);
                return SourceDestOracle;
            }
        }///Fin extraire données

        public void LoadOracle(DataTable Ds, OracleConnection Cn)
        {

            int IDCLIENT;
            String NOM;
            String PRENOM;
            String SEXE;
            int AGE;
            String VILLE;
            string Requete;
            DataTableReader DR;

            try
            {
                DR = Ds.CreateDataReader();
                DateTime TempsLoadORACLE = DateTime.Now;
                while (DR.Read())
                {

                    string val;
                    val = DR[0].ToString();
                    IDCLIENT = Convert.ToInt32(val);
                    NOM = DR[1].ToString();
                    PRENOM = DR[2].ToString();
                    SEXE = DR[3].ToString();
                    val = DR[4].ToString();
                    AGE = Convert.ToInt32(val);
                    VILLE = DR[5].ToString();
                    Requete = "INSERT INTO CLIENTDEST (NOM,PRENOM,SEXE,AGE,VILLE,IDCLIENT) VALUES ('" + NOM + "','" + PRENOM + "','" + SEXE + "'," + AGE + ",'" + VILLE + "'," + IDCLIENT + ")";
                    OracleCommand Cmd1 = new OracleCommand(Requete, Cn);
                    //Cmd1.Prepare();
                    Cmd1.ExecuteNonQuery();
                }

                TimeSpan TempsEcoule = DateTime.Now.Subtract(TempsLoadORACLE);

                MessageBox.Show("Chargement ORACLE effectué avec succé \n  Le temps de chargement de données est : " + TempsEcoule.TotalMilliseconds.ToString() + " Mellisecondes");

                DR.Close();

            }
            catch (Exception e)
            {
                MessageBox.Show("Chargement ORACLE Impossible " + e);
            }
        }

    }///Fin classe Oracle







    /// <summary>
    /// Classe SQL Server connexion déconnexion extraire loder
    /// </summary>

    public class SqlConnect
    {


        ///Methode connecter SQL server
        public SqlConnection ConnectSql(string ServeurSql, string BaseSql, string UserSql, string PasswordSql)
        {
            System.Data.SqlClient.SqlConnection SqlCon = new SqlConnection();
            string conString;/// chemin de connexion oracle
            conString = "Data Source=" + ServeurSql + "; Initial Catalog =" + BaseSql + "; User Id =" + UserSql + "; Password = " + PasswordSql + ";";
            SqlCon.ConnectionString = conString;
            try
            {
                SqlCon.Open();
                MessageBox.Show("Connexion SQL Server effectuée avec succé");
                return SqlCon;
            }
            catch (Exception e)
            {
                MessageBox.Show("Connexion SQL Server impossible " + e);
                return SqlCon;
            }
        }///fin Connect



        /// Methode Déconnexion SQL Server

        public bool DisconnectSql(SqlConnection SqlCon)
        {
            try
            {
                SqlCon.Close();
                MessageBox.Show("Déconnnexion SQL Server effectuée avec succé");
                return false;
            }
            catch (Exception e)
            {
                MessageBox.Show("Déconnecion SQL Server Impossible " + e);
                return false;
            }


        }///Fin disconnect



        ///Extraire les données
        public DataTable ExtractSql(string Requete, SqlConnection Cn)
        {
            int i = 0;

            DataRow Tableau;
            SqlDataReader DSResultat;

            DataTable SourceDestSql = new DataTable("Test");
            System.Data.DataColumn ColID;
            System.Data.DataColumn ColNOM;
            System.Data.DataColumn ColPRENOM;
            System.Data.DataColumn ColSEXE;
            System.Data.DataColumn ColAGE;
            System.Data.DataColumn ColVILLE;

            ColID = new DataColumn();
            ColNOM = new DataColumn();
            ColPRENOM = new DataColumn();
            ColSEXE = new DataColumn();
            ColAGE = new DataColumn();
            ColVILLE = new DataColumn();
            try
            {
                ColID.DataType = System.Type.GetType("System.Int32");
                ColID.ColumnName = "IDCLIENT";
                SourceDestSql.Columns.Add(ColID);

                ColNOM.DataType = System.Type.GetType("System.String");
                ColNOM.ColumnName = "NOM";
                SourceDestSql.Columns.Add(ColNOM);

                ColPRENOM.DataType = System.Type.GetType("System.String");
                ColPRENOM.ColumnName = "PRENOM";
                SourceDestSql.Columns.Add(ColPRENOM);

                ColSEXE.DataType = System.Type.GetType("System.String");
                ColSEXE.ColumnName = "SEXE";
                SourceDestSql.Columns.Add(ColSEXE);

                ColAGE.DataType = System.Type.GetType("System.Int32");
                ColAGE.ColumnName = "AGE";
                SourceDestSql.Columns.Add(ColAGE);

                ColVILLE.DataType = System.Type.GetType("System.String");
                ColVILLE.ColumnName = "VILLE";
                SourceDestSql.Columns.Add(ColVILLE);


            }
            catch (Exception)
            {
                MessageBox.Show("Impossible de créer data TAble");
            }


            try
            {
                SqlCommand Cmd = new SqlCommand(Requete, Cn);
                DSResultat = Cmd.ExecuteReader();
                DateTime TempsExtractSql = DateTime.Now;

                while (DSResultat.Read())
                {
                    Tableau = SourceDestSql.NewRow();

                    Tableau["IDCLIENT"] = DSResultat.GetValue(0);
                    Tableau["NOM"] = DSResultat.GetString(1);
                    Tableau["PRENOM"] = DSResultat.GetString(2);
                    Tableau["SEXE"] = DSResultat.GetString(3);
                    Tableau["AGE"] = DSResultat.GetInt32(4);
                    Tableau["VILLE"] = DSResultat.GetString(5);
                    SourceDestSql.Rows.Add(Tableau);
                    i++;
                }
                TimeSpan TempsEcoule = DateTime.Now.Subtract(TempsExtractSql);
                MessageBox.Show("Extraction SQL Effectuée avec succé  \n Le temps d'extraction de données est : " + TempsEcoule.TotalMilliseconds.ToString() + " Mellisecondes");

                DSResultat.Close();
                return SourceDestSql;
            }
            catch (Exception)
            {
                MessageBox.Show("Extraction SQL Server impossible");
                return SourceDestSql;
            }
        }///Fin extraire données


        ///Methode insertion de données SQL Server

        public void LoadSql(DataTable Ds, SqlConnection Cn)
        {

            int IDCLIENT;
            String NOM;
            String PRENOM;
            String SEXE;
            int AGE;
            String VILLE;
            string Requete;
            SqlConnection Cnx = new SqlConnection();
            Cnx = Cn;
            try
            {
                DataTableReader DR = Ds.CreateDataReader();
                DateTime TempsLoadSql = DateTime.Now;
                while (DR.Read())
                {

                    string val;
                    val = DR[0].ToString();
                    IDCLIENT = Convert.ToInt32(val);
                    NOM = DR[1].ToString();
                    PRENOM = DR[2].ToString();
                    SEXE = DR[3].ToString();
                    val = DR[4].ToString();
                    AGE = Convert.ToInt32(val);
                    VILLE = DR[5].ToString();
                    Requete = "INSERT INTO CLIENTdest(NOM,PRENOM,SEXE,AGE,VILLE,IDCLIENT) VALUES ('" + NOM + "','" + PRENOM + "','" + SEXE + "'," + AGE + ",'" + VILLE + "'," + IDCLIENT + ")";

                    SqlCommand Cmd = new SqlCommand(Requete, Cnx);
                    Cmd.Prepare();
                    Cmd.ExecuteNonQuery();
                }

                TimeSpan TempsEcoule = DateTime.Now.Subtract(TempsLoadSql);

                MessageBox.Show("Chargement SQL effectué avec succé \n  Le temps de chargement de données est : " + TempsEcoule.TotalMilliseconds.ToString() + " Mellisecondes");
            }
            catch (Exception e)
            {
                MessageBox.Show("Chargement SQL Impossible " + e);
            }
        }///Fin Load SQL Server

    }///Fin classe SQL Server



    ///Classe Fichier Csv
    public class ConnectCSV
    {

        public StreamReader fichier;

        ///Méthode permettant d'ouvrir un fichier
        public StreamReader CSVConnection(string FichierCSV)
        {
            try
            {
                fichier = File.OpenText(FichierCSV);
                MessageBox.Show("Connexion CSV effectuée avec succé");
            }
            catch (Exception)
            {
                MessageBox.Show("Impossible d'ouvrir le fichier CSV");
            }
            return fichier;
        }///Fin connecter CSV
        ///

        public void CSVDisconnection(StreamReader FichierCSV)
        {
            try
            {
                FichierCSV.Close();
                MessageBox.Show("Fermeture CSV effectuée avec succé");
            }
            catch (Exception)
            {
                MessageBox.Show("Impossible de efrmer le fichier CSV");
            }

        }


        ///Methode extraction csv
        public DataTable ExtractCSV(StreamReader Fichier)
        {


            DataRow Tableau;
            DataTable SourceDestCSV = new DataTable("Test");
            System.Data.DataColumn ColID;
            System.Data.DataColumn ColNOM;
            System.Data.DataColumn ColPRENOM;
            System.Data.DataColumn ColSEXE;
            System.Data.DataColumn ColAGE;
            System.Data.DataColumn ColVILLE;

            ColID = new DataColumn();
            ColNOM = new DataColumn();
            ColPRENOM = new DataColumn();
            ColSEXE = new DataColumn();
            ColAGE = new DataColumn();
            ColVILLE = new DataColumn();
            try
            {
                ColID.DataType = System.Type.GetType("System.Int32");
                ColID.ColumnName = "IDCLIENT";
                SourceDestCSV.Columns.Add(ColID);

                ColNOM.DataType = System.Type.GetType("System.String");
                ColNOM.ColumnName = "NOM";
                SourceDestCSV.Columns.Add(ColNOM);

                ColPRENOM.DataType = System.Type.GetType("System.String");
                ColPRENOM.ColumnName = "PRENOM";
                SourceDestCSV.Columns.Add(ColPRENOM);

                ColSEXE.DataType = System.Type.GetType("System.String");
                ColSEXE.ColumnName = "SEXE";
                SourceDestCSV.Columns.Add(ColSEXE);

                ColAGE.DataType = System.Type.GetType("System.Int32");
                ColAGE.ColumnName = "AGE";
                SourceDestCSV.Columns.Add(ColAGE);

                ColVILLE.DataType = System.Type.GetType("System.String");
                ColVILLE.ColumnName = "VILLE";
                SourceDestCSV.Columns.Add(ColVILLE);


            }
            catch (Exception)
            {
                MessageBox.Show("Impossible de créer data TAble");
            }


            string titre = fichier.ReadLine();
            try
            {
                DateTime TempsExtractCSV = DateTime.Now;

                while (fichier.Peek() >= 0)
                {
                    /// on lit 1 ligne et on ajoute au tabeau

                    string ligne = fichier.ReadLine();
                    string[] vals = ligne.Split(';');
                    Tableau = SourceDestCSV.NewRow();

                    Tableau["IDCLIENT"] = Convert.ToDecimal(vals[0]);
                    Tableau["NOM"] = vals[1];
                    Tableau["PRENOM"] = vals[2];
                    Tableau["SEXE"] = vals[3];
                    Tableau["AGE"] = Convert.ToDecimal(vals[5]);
                    Tableau["VILLE"] = vals[4];
                    SourceDestCSV.Rows.Add(Tableau);

                }
                TimeSpan TempsEcoule = DateTime.Now.Subtract(TempsExtractCSV);
                MessageBox.Show("Extraction CSV Effectuée avec succé  \n Le temps d'extraction de données est : " + TempsEcoule.TotalMilliseconds.ToString() + " Mellisecondes");
            }
            catch (Exception e)
            {
                MessageBox.Show("Impossible d'extraire les données CSV " + e);
            }

            return SourceDestCSV;
        }///Fin Méthode extraction CSV
        ///



        ///Début méthode Load (insertion) CSV
        public void LoadCSV(DataTable Ds, StreamWriter Fichier)
        {
            int IDCLIENT;
            String NOM;
            String PRENOM;
            String SEXE;
            int AGE;
            String VILLE;
            string Requete;


            try
            {
                DataTableReader DR = Ds.CreateDataReader();
                DateTime TempsLoadCSV = DateTime.Now;
                ///Ecriture de l'entete du fichier
                Fichier.WriteLine("IDCLIENT NOM,PRENOM,SEXE,AGE,VILLE;");
                ///Remplisssage des données après l'entête
                while (DR.Read())
                {

                    string val;
                    val = DR[0].ToString();
                    IDCLIENT = Convert.ToInt32(val);
                    NOM = DR[1].ToString();
                    PRENOM = DR[2].ToString();
                    SEXE = DR[3].ToString();
                    val = DR[4].ToString();
                    AGE = Convert.ToInt32(val);
                    VILLE = DR[4].ToString();
                    Fichier.WriteLine(IDCLIENT.ToString() + "," + NOM + "," + PRENOM + "," + SEXE + "," + AGE.ToString() + "," + VILLE + ";");
                }

                TimeSpan TempsEcoule = DateTime.Now.Subtract(TempsLoadCSV);

                MessageBox.Show("Chargement CSV effectué avec succé \n  Le temps de chargement de données est : " + TempsEcoule.TotalMilliseconds.ToString() + " Mellisecondes");
            }
            catch (Exception e)
            {
                MessageBox.Show("Chargement SQL Impossible " + e);
            }

        }///Fin méthde load CSV




    }///Fin classe CSV  
     

}///Fin namespace