<?xml version="1.0" encoding="utf-8"?>
<personne>
  <line>
    <id>1</id>
    <nom>Toto</nom>
  </line>
  <line>
    <id>2</id>
    <nom>Alfred</nom>
  </line>
  <line>
    <id>3</id>
    <nom>Tintin</nom>
  </line>
</personne>

<?xml version="1.0" encoding="utf-8"?>
<dataset>
  <tableshema>
    <table>
      <name>personne</name>
      <columns>
          <column name="id" type="numeric" size="18" withnull="no"/>
          <column name="nom" type="varchar" size="50" withnull="yes"/>
      </columns>
    </table>
  </tableshema>
  <tabledata>
    <personne id="1" nom="Toto"/>
    <personne id="2" nom="Alfred"/>
    <personne id="3" nom="Tintin"/>
  </tabledata>
</dataset>

using System;
using System.Data;
using Oracle.DataAccess.Client;
using System.IO;
using System.IO.Compression;
using System.Text;
 
namespace DatabaseMaker
{
    /// <summary>
    /// Outil d'extraction de différenciels de la base Générix
    /// </summary>
    public class DatabaseExtractor
    {
        OracleConnection cnx;
        string datdeb;
        string datfin;
        decimal[] aCodsoc;
        string[] aCodlan;
 
        string outPath;
 
        DataSet ds;
 
        /// <summary>
        /// Instancie l'outil d'extraction de différenciels de la base Générix
        /// </summary>
        /// <param name="OpenedCnx">Connection active vers la base Générix</param>
        /// <param name="OutPath">Répertoire de sortie pour les fichiers compressés</param>
        /// <param name="Codsoc">Liste des code sociétés à exporter</param>
        public DatabaseExtractor(OracleConnection OpenedCnx, string OutPath, decimal[] Codsoc)
        {
            cnx = OpenedCnx;
            outPath = OutPath;
            aCodsoc = Codsoc;
        }
 
        /// <summary>
        /// Extraction du différenciel sur une période donnée
        /// Un fichier compressé est généré par société
        /// Et chaque fichier compressé contient l'ensemble des éléments exportés séparés en fichiers 
        /// contenant à chaque fois les données d'une table pour une langue donnée
        /// </summary>
        /// <param name="Datdeb">Date de début de l'extraction. Laisser vide pour exporter depuis le début.</param>
        /// <param name="Datfin">Date de fin. Obligatoirement présent. La date du jour en général.</param>
        public void Extract(string Datdeb, string Datfin)
        {
            this.datdeb = Datdeb;
            this.datfin = Datfin;
 
            // Extraction pour chaque société
            for (int i = 0, cpti = aCodsoc.Length; i < cpti; i++)
            {
                // Création du DataSet
                ds = new DataSet();
 
                // Extraction des éléments de base
                ExtractFamilies(aCodsoc[i]);
                ExtractCritera(aCodsoc[i]);
 
                // Chargement des langues
                LoadCodlan(aCodsoc[i]);
 
                // Extraction des libellés
                ExtractFamiliesLabels(aCodsoc[i]);
                ExtractCriteriaLabels(aCodsoc[i]);
 
                if (ds.Tables.Count > 0)
                {
                    // Flux en entrée
                    MemoryStream ms = new MemoryStream();
                    ds.WriteXml(ms, XmlWriteMode.WriteSchema);
                    ms.Position = 0;
 
                    // Compression du fichier
                    byte[] buffer = new byte[4096];
                    FileStream dest = new FileStream(string.Format("{0}\\SOC{1}_DEB{2}_FIN{3}.gz", outPath, aCodsoc[i], datdeb, datfin), FileMode.Create, FileAccess.Write, FileShare.None);
                    GZipStream gz = new GZipStream(dest, CompressionMode.Compress, false);
                    while (true)
                    {
                        int bytes_read = ms.Read(buffer, 0, buffer.Length);
                        if (bytes_read == 0)
                        {
                            break;
                        }
                        gz.Write(buffer, 0, bytes_read);
                    }
                    gz.Close();
                    ms.Close();
                }
            }
        }
 
        /// <summary>
        /// Chargement des code langue pour une société donnée
        /// </summary>
        /// <param name="codsoc">Société à charger</param>
        private void LoadCodlan(decimal codsoc)
        {
            OracleCommand cmd = this.cnx.CreateCommand();
            cmd.CommandText = "select cletbl codlan from tbl where codsoc = :codsoc and codtbl = 'lan'";
            cmd.CommandType = CommandType.Text;
 
            OracleParameter p1 = cmd.CreateParameter();
            p1.Direction = ParameterDirection.Input;
            p1.OracleDbType = OracleDbType.Decimal;
            p1.ParameterName = "codsoc";
            p1.Size = 38;
            p1.Value = codsoc;
            cmd.Parameters.Add(p1);
 
 
            DataTable dt = new DataTable();
            OracleDataAdapter da = new OracleDataAdapter(cmd);
            da.Fill(dt);
 
            int cpt = dt.Rows.Count;
            aCodlan = new string[cpt];
 
            for (int i = 0; i < cpt; i++)
            {
                aCodlan[i] = (string)dt.Rows[i]["codlan"];
            }
        }
 
        #region Données de base
 
        /// <summary>
        /// Extraction des familles biblo (premier niveau)
        /// </summary>
        /// <param name="codsoc">Société à extraire</param>
        private void ExtractFamilies(decimal codsoc)
        {
            OracleCommand cmd = this.cnx.CreateCommand();
            cmd.BindByName = true;
            cmd.CommandText = "select codsoc, codmdl codfam from mdl where codsoc = :codsoc";
            cmd.CommandType = CommandType.Text;
 
            OracleParameter p1 = cmd.CreateParameter();
            p1.Direction = ParameterDirection.Input;
            p1.OracleDbType = OracleDbType.Decimal;
            p1.ParameterName = "codsoc";
            p1.Size = 38;
            p1.Value = codsoc;
            cmd.Parameters.Add(p1);
 
            DataTable dt = new DataTable("fam" );
            OracleDataAdapter da = new OracleDataAdapter(cmd);
            da.Fill(dt);
 
            if (dt.Rows.Count > 0)
            {
                ds.Tables.Add(dt);
            }
        }
 
        /// <summary>
        /// Extraction des critères biblo
        /// </summary>
        /// <param name="codsoc">Société à extraire</param>
        private void ExtractCritera(decimal codsoc)
        {
            OracleCommand cmd = this.cnx.CreateCommand();
            cmd.BindByName = true;
            cmd.CommandText = "select distinct codsoc, indzon codcri from zodm where codsoc = :codsoc";
            cmd.CommandType = CommandType.Text;
 
            OracleParameter p1 = cmd.CreateParameter();
            p1.Direction = ParameterDirection.Input;
            p1.OracleDbType = OracleDbType.Decimal;
            p1.ParameterName = "codsoc";
            p1.Size = 38;
            p1.Value = codsoc;
            cmd.Parameters.Add(p1);
 
            DataTable dt = new DataTable("cri" );
            OracleDataAdapter da = new OracleDataAdapter(cmd);
            da.Fill(dt);
 
            if (dt.Rows.Count > 0)
            {
                ds.Tables.Add(dt);
            }
        }
 
        #endregion
 
        # region Libellés
 
        /// <summary>
        /// Extraction des libellés des familles biblo
        /// </summary>
        /// <param name="codsoc">Société à extraire</param>
        private void ExtractFamiliesLabels(decimal codsoc)
        {
            OracleCommand cmd = this.cnx.CreateCommand();
            cmd.BindByName = true;
            cmd.CommandType = CommandType.Text;
 
            string tmpCommandText = "select mdl.codsoc, tbl.cletbl codlan, mdl.codmdl codfam, mdl.libmdl libfam from mdl inner join tbl on tbl.codsoc = mdl.codsoc and tbl.codtbl = 'lan' and tbl.cletbl in ({0}) where mdl.codsoc = :codsoc";
            StringBuilder lanlist = new StringBuilder(":codlan0" );
 
            OracleParameter pLan = cmd.CreateParameter();
            pLan.Direction = ParameterDirection.Input;
            pLan.OracleDbType = OracleDbType.Varchar2;
            pLan.ParameterName = "codlan0";
            pLan.Size = 3;
            pLan.Value = aCodlan[0];
            cmd.Parameters.Add(pLan);
 
            for (int i = 1, cpt = aCodlan.Length; i < cpt; i++)
            {
                lanlist.Append(", :codlan" );
                lanlist.Append(i);
 
                OracleParameter p = cmd.CreateParameter();
                p.Direction = ParameterDirection.Input;
                p.OracleDbType = OracleDbType.Varchar2;
                p.ParameterName = string.Format("codlan{0}", i);
                p.Size = 3;
                p.Value = aCodlan[i];
                cmd.Parameters.Add(p);
            }
            cmd.CommandText = string.Format(tmpCommandText, lanlist.ToString());
 
            OracleParameter p1 = cmd.CreateParameter();
            p1.Direction = ParameterDirection.Input;
            p1.OracleDbType = OracleDbType.Decimal;
            p1.ParameterName = "codsoc";
            p1.Size = 38;
            p1.Value = codsoc;
            cmd.Parameters.Add(p1);
 
            DataTable dt = new DataTable("lblfam" );
            OracleDataAdapter da = new OracleDataAdapter(cmd);
            da.Fill(dt);
 
            if (dt.Rows.Count > 0)
            {
                ds.Tables.Add(dt);
            }
        }
 
        /// <summary>
        /// Extraction des libellés des critères biblo
        /// </summary>
        /// <param name="codsoc">Société à extraire</param>
        /// <param name="codlan">Langue à extraire</param>
        private void ExtractCriteriaLabels(decimal codsoc)
        {
            OracleCommand cmd = this.cnx.CreateCommand();
            cmd.BindByName = true;
            string tmpCommandText = "select distinct zodm.codsoc, nvl(zonlan.codlan, lan.cletbl) codlan, zodm.indzon codcri, nvl(zonlan.lib1, zon.lib1) libcri " +
                                "from zodm " +
                                "inner join tbl lan on lan.codsoc = zodm.codsoc and lan.codtbl = 'lan' and lan.cletbl in ({0}) " +
                                "inner join tbl zon on zon.codsoc = zodm.codsoc and zon.codtbl = 'zon' and zon.cletbl = zodm.indzon " +
                                "left outer join tbllan zonlan on zonlan.codsoc = zon.codsoc and zonlan.codtbl = 'zon' and zonlan.cletbl = zon.cletbl and zonlan.codlan = lan.cletbl " +
                                "where zodm.codsoc = :codsoc";
            cmd.CommandType = CommandType.Text;
 
            StringBuilder lanlist = new StringBuilder(":codlan0" );
 
            OracleParameter pLan = cmd.CreateParameter();
            pLan.Direction = ParameterDirection.Input;
            pLan.OracleDbType = OracleDbType.Varchar2;
            pLan.ParameterName = "codlan0";
            pLan.Size = 3;
            pLan.Value = aCodlan[0];
            cmd.Parameters.Add(pLan);
 
            for (int i = 1, cpt = aCodlan.Length; i < cpt; i++)
            {
                lanlist.Append(", :codlan" );
                lanlist.Append(i);
 
                OracleParameter p = cmd.CreateParameter();
                p.Direction = ParameterDirection.Input;
                p.OracleDbType = OracleDbType.Varchar2;
                p.ParameterName = string.Format("codlan{0}", i);
                p.Size = 3;
                p.Value = aCodlan[i];
                cmd.Parameters.Add(p);
            }
            cmd.CommandText = string.Format(tmpCommandText, lanlist.ToString());
 
            OracleParameter p1 = cmd.CreateParameter();
            p1.Direction = ParameterDirection.Input;
            p1.OracleDbType = OracleDbType.Decimal;
            p1.ParameterName = "codsoc";
            p1.Size = 38;
            p1.Value = codsoc;
            cmd.Parameters.Add(p1);
 
            DataTable dt = new DataTable("lblcri" );
            OracleDataAdapter da = new OracleDataAdapter(cmd);
            da.Fill(dt);
 
            if (dt.Rows.Count > 0)
            {
                ds.Tables.Add(dt);
            }
        }
 
        #endregion
    }
}

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.IO.Compression;
using System.Net;
using System.Windows.Forms;
using System.Xml;
 
namespace CatalogueOnlineClient
{
    public partial class MajAuto : Form
    {
        Parameters p;
        SqlConnection cnx;
        SocInfo[] s;
 
        public MajAuto(Parameters p, SocInfo[] s, SqlConnection cnx)
        {
            InitializeComponent();
            this.p = p;
            this.s = s;
            this.cnx = cnx;
 
            SqlCommand cmd = cnx.CreateCommand();
            cmd.CommandType = CommandType.Text;
            cmd.CommandText = "delete soc";
            cmd.ExecuteNonQuery();
            cmd.CommandText = "delete lan";
            cmd.ExecuteNonQuery();
 
            SqlParameter pCodsoc = cmd.CreateParameter();
            pCodsoc.Direction = ParameterDirection.Input;
            pCodsoc.ParameterName = "codsoc";
            pCodsoc.Size = 18;
            pCodsoc.SqlDbType = SqlDbType.Decimal;
 
            SqlParameter pLibsoc = cmd.CreateParameter();
            pLibsoc.Direction = ParameterDirection.Input;
            pLibsoc.ParameterName = "libsoc";
            pLibsoc.Size = 50;
            pLibsoc.SqlDbType = SqlDbType.VarChar;
 
            SqlParameter pCodlan = cmd.CreateParameter();
            pCodlan.Direction = ParameterDirection.Input;
            pCodlan.ParameterName = "codlan";
            pCodlan.Size = 3;
            pCodlan.SqlDbType = SqlDbType.VarChar;
 
            SqlParameter pLiblan = cmd.CreateParameter();
            pLiblan.Direction = ParameterDirection.Input;
            pLiblan.ParameterName = "liblan";
            pLiblan.Size = 50;
            pLiblan.SqlDbType = SqlDbType.VarChar;
 
            cmd.Parameters.Add(pCodsoc);
 
            for (int i = 0, cpti = s.Length; i < cpti; i++)
            {
                cmd.Parameters.Add(pLibsoc);
 
                cmd.CommandText = "insert into soc (codsoc, libsoc) values (@codsoc, @libsoc)";
                pCodsoc.Value = s[i].codsoc;
                pLibsoc.Value = s[i].libsoc;
                cmd.ExecuteNonQuery();
                
                cmd.Parameters.Remove(pLibsoc);
 
                cmd.Parameters.Add(pCodlan);
                cmd.Parameters.Add(pLiblan);
 
                cmd.CommandText = "insert into lan (codsoc, codlan, liblan) values (@codsoc, @codlan, @liblan)";
                for (int j = 0, cptj = s[i].laninfo.Length; j < cptj; j++)
                {
                    pCodlan.Value = s[i].laninfo[j].codlan;
                    pLiblan.Value = s[i].laninfo[j].liblan;
                    cmd.ExecuteNonQuery();
                }
 
                cmd.Parameters.Remove(pCodlan);
                cmd.Parameters.Remove(pLiblan);
            }
        }
 
        private void MajAuto_Load(object sender, EventArgs e)
        {
            this.Visible = true;
            this.Refresh();
            string lastUpdate = p["LAST"];
 
            WebClient wc = new WebClient();
            XmlDocument dom = new XmlDocument();
            dom.LoadXml(wc.DownloadString(string.Format("http://192.168.0.2/test.php?deb={0}", lastUpdate)));
            progressBar1.Maximum = dom.DocumentElement.ChildNodes.Count - 1;
            progressBar2.Maximum = dom.DocumentElement.ChildNodes.Count - 1;
 
            foreach (XmlElement el in dom.DocumentElement.ChildNodes)
            {
                wc.DownloadFile(string.Format("http://192.168.0.2/{0}", el.InnerText), string.Format("./in/{0}", el.InnerText));
                progressBar1.PerformStep();
            }
 
            foreach (string file in Directory.GetFiles("in", "*.gz" ))
            {
                // Décompresser le gz dans un ms, puis passer directement dans un ds
                FileStream fs = new FileStream(file, FileMode.Open, FileAccess.Read, FileShare.Read);
                MemoryStream ms = new MemoryStream();
                GZipStream gz = new GZipStream(fs, CompressionMode.Decompress, false);
                byte[] buffer = new byte[4096];
                while (true)
                {
                    int read_bytes = gz.Read(buffer, 0, buffer.Length);
                    if (read_bytes == 0)
                    {
                        break;
                    }
                    ms.Write(buffer, 0, read_bytes);
                }
                gz.Close();
                fs.Close();
                File.Delete(file);
                DataSet ds = new DataSet();
                ms.Position = 0;
                ds.ReadXml(ms, XmlReadMode.ReadSchema);
 
                string dir = file.Substring(0, file.LastIndexOf('.'));
                string tmpCodsoc = file.Substring(file.LastIndexOf("\\SOC" ) + 4);
                decimal codsoc = decimal.Parse(tmpCodsoc.Substring(0, tmpCodsoc.IndexOf('_')));
 
                foreach (DataTable dt in ds.Tables)
                {
                    switch (dt.TableName)
                    {
                        // Données de base
                        case "fam":
                            UpdateFam(codsoc, dt);
                            break;
                        case "cri":
                            UpdateCri(codsoc, dt);
 
                        // Libellés
                        case "lblfam":
                            UpdateLblFam(codsoc, dt);
                            break;
                        case "lblcri":
                            UpdateLblCri(codsoc, dt);
 
                        // Ca chie des bulles
                        default:
                            throw new Exception(string.Format("Table \"{0}\" non reconnue dans le fichier \"{1}\" !", dt.TableName, file))
                            break;
                    }
                }
                progressBar2.PerformStep();
            }
            this.Close();
        }
 
        #region Données de base
        private void UpdateFam(decimal codsoc, DataTable dt)
        {
            SqlCommand cmd = cnx.CreateCommand();
            cmd.CommandType = CommandType.Text;
            cmd.CommandText = "delete fam where codsoc = @codsoc";
 
            SqlParameter pCodsoc = cmd.CreateParameter();
            pCodsoc.Direction = ParameterDirection.Input;
            pCodsoc.ParameterName = "codsoc";
            pCodsoc.Size = 18;
            pCodsoc.SqlDbType = SqlDbType.Decimal;
            cmd.Parameters.Add(pCodsoc);
 
            pCodsoc.Value = codsoc;
            cmd.ExecuteNonQuery();
 
            cmd.CommandText = "insert into fam (codsoc, codfam) values (@codsoc, @codfam)";
            SqlParameter pCodfam = cmd.CreateParameter();
            pCodfam.Direction = ParameterDirection.Input;
            pCodfam.ParameterName = "codfam";
            pCodfam.Size = 6;
            pCodfam.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pCodfam);
 
            foreach (DataRow dr in dt.Rows)
            {
                pCodfam.Value = (string)dr["CODFAM"];
                cmd.ExecuteNonQuery();
            }
        }
 
        private void UpdateCri(decimal codsoc, DataTable dt)
        {
            SqlCommand cmd = cnx.CreateCommand();
            cmd.CommandType = CommandType.Text;
            cmd.CommandText = "delete cri where codsoc = @codsoc";
 
            SqlParameter pCodsoc = cmd.CreateParameter();
            pCodsoc.Direction = ParameterDirection.Input;
            pCodsoc.ParameterName = "codsoc";
            pCodsoc.Size = 18;
            pCodsoc.SqlDbType = SqlDbType.Decimal;
            cmd.Parameters.Add(pCodsoc);
 
            pCodsoc.Value = codsoc;
            cmd.ExecuteNonQuery();
 
            cmd.CommandText = "insert into cri (codsoc, codcri) values (@codsoc, @codcri)";
            SqlParameter pCodfam = cmd.CreateParameter();
            pCodfam.Direction = ParameterDirection.Input;
            pCodfam.ParameterName = "codcri";
            pCodfam.Size = 6;
            pCodfam.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pCodfam);
 
            foreach (DataRow dr in dt.Rows)
            {
                pCodfam.Value = (string)dr["CODCRI"];
                cmd.ExecuteNonQuery();
            }
        }
        #endregion
 
        #region Libellés
        private void UpdateLblFam(decimal codsoc, DataTable dt)
        {
            SqlCommand cmd = cnx.CreateCommand();
            cmd.CommandType = CommandType.Text;
            cmd.CommandText = "delete lbl where codsoc = @codsoc and codtbl = 'fam'";
 
            SqlParameter pCodsoc = cmd.CreateParameter();
            pCodsoc.Direction = ParameterDirection.Input;
            pCodsoc.ParameterName = "codsoc";
            pCodsoc.Size = 18;
            pCodsoc.SqlDbType = SqlDbType.Decimal;
            cmd.Parameters.Add(pCodsoc);
 
            pCodsoc.Value = codsoc;
            cmd.ExecuteNonQuery();
 
            cmd.CommandText = "insert into lbl (codsoc, codtbl, sigti1, sigti2, codlan, label) values (@codsoc, 'fam', @codfam, '', @codlan, @label)";
            SqlParameter pCodfam = cmd.CreateParameter();
            pCodfam.Direction = ParameterDirection.Input;
            pCodfam.ParameterName = "codfam";
            pCodfam.Size = 6;
            pCodfam.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pCodfam);
            SqlParameter pCodlan = cmd.CreateParameter();
            pCodlan.Direction = ParameterDirection.Input;
            pCodlan.ParameterName = "codlan";
            pCodlan.Size = 3;
            pCodlan.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pCodlan);
            SqlParameter pLabel = cmd.CreateParameter();
            pLabel.Direction = ParameterDirection.Input;
            pLabel.ParameterName = "label";
            pLabel.Size = 50;
            pLabel.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pLabel);
 
            foreach (DataRow dr in dt.Rows)
            {
                pCodfam.Value = (string)dr["CODFAM"];
                pCodlan.Value = (string)dr["CODLAN"];
                pLabel.Value = (string)dr["LIBFAM"];
                cmd.ExecuteNonQuery();
            }
        }
 
        private void UpdateLblCri(decimal codsoc, DataTable dt)
        {
            SqlCommand cmd = cnx.CreateCommand();
            cmd.CommandType = CommandType.Text;
            cmd.CommandText = "delete lbl where codsoc = @codsoc and codtbl = 'cri'";
 
            SqlParameter pCodsoc = cmd.CreateParameter();
            pCodsoc.Direction = ParameterDirection.Input;
            pCodsoc.ParameterName = "codsoc";
            pCodsoc.Size = 18;
            pCodsoc.SqlDbType = SqlDbType.Decimal;
            cmd.Parameters.Add(pCodsoc);
 
            pCodsoc.Value = codsoc;
            cmd.ExecuteNonQuery();
 
            cmd.CommandText = "insert into cri (codsoc, codtbl, sigti1, sigti2, codlan, label) values (@codsoc, 'cri', @codcri, '', @codlan, @label)";
            SqlParameter pCodfam = cmd.CreateParameter();
            pCodfam.Direction = ParameterDirection.Input;
            pCodfam.ParameterName = "codcri";
            pCodfam.Size = 6;
            pCodfam.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pCodfam);
            SqlParameter pCodlan = cmd.CreateParameter();
            pCodlan.Direction = ParameterDirection.Input;
            pCodlan.ParameterName = "codlan";
            pCodlan.Size = 3;
            pCodlan.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pCodlan);
            SqlParameter pLabel = cmd.CreateParameter();
            pLabel.Direction = ParameterDirection.Input;
            pLabel.ParameterName = "label";
            pLabel.Size = 50;
            pLabel.SqlDbType = SqlDbType.VarChar;
            cmd.Parameters.Add(pLabel);
 
            foreach (DataRow dr in dt.Rows)
            {
                pCodfam.Value = (string)dr["CODCRI"];
                pCodlan.Value = (string)dr["CODLAN"];
                pLabel.Value = (string)dr["LIBCRI"];
                cmd.ExecuteNonQuery();
            }
        }
        #endregion
    }
}