1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75
| if (System.IO.File.Exists("fichier.csv"))
{
StreamReader sr = null;
string line;
try
{
//chaine de connexion
string connectString = condatabul;
//Objet de connexion
SqlCeConnection connection = new SqlCeConnection(connectString);
string sSQL = "INSERT INTO client (code_cli,code_site,nom,add_cli,add_clic,code_postale,ville) VALUES (?,?,?,?,?,?,?)";
SqlCeCommand sqlcmd = new SqlCeCommand(sSQL, connection);
// Ouverture du fichier et écriture du contenu du fichier sur la console
sr = new StreamReader("fichier.csv");
line = sr.ReadLine();
while (!sr.EndOfStream)
{
SqlCeParameter co = new SqlCeParameter("code_cli", SqlDbType.NVarChar);
co.Value = line.Split(';')[0];
SqlCeParameter si = new SqlCeParameter("code_site", SqlDbType.NVarChar);
si.Value = line.Split(';')[1];
SqlCeParameter no = new SqlCeParameter("nom", SqlDbType.NVarChar);
no.Value = line.Split(';')[2];
SqlCeParameter ad = new SqlCeParameter("add_cli", SqlDbType.NVarChar);
ad.Value = line.Split(';')[3];
SqlCeParameter ac = new SqlCeParameter("add_clic", SqlDbType.NVarChar);
ac.Value = line.Split(';')[4];
SqlCeParameter pt = new SqlCeParameter("code_postale", SqlDbType.NVarChar);
pt.Value = line.Split(';')[5];
SqlCeParameter vl = new SqlCeParameter("ville", SqlDbType.NVarChar);
vl.Value = line.Split(';')[6];
sqlcmd.Parameters.Add(co);
sqlcmd.Parameters.Add(si);
sqlcmd.Parameters.Add(no);
sqlcmd.Parameters.Add(ad);
sqlcmd.Parameters.Add(ac);
sqlcmd.Parameters.Add(pt);
sqlcmd.Parameters.Add(vl);
//ouverture
connection.Open();
//commande exectuter a chaque saut de ligne
sqlcmd.Prepare();
sqlcmd.ExecuteNonQuery();
if (connection.State == ConnectionState.Open)
{
connection.Close();
}
//saut de ligne
line = sr.ReadLine();
}
}
catch (SqlCeException ex)
{
MessageBox.Show("erreur SQL inattendue.\n" + ex.Message, "Erreur");
}
catch (Exception ex)
{
MessageBox.Show("erreur interne inattendue.\n" + ex.Message, "Erreur");
}
finally
{
// Fermeture streamreader
if (sr != null) sr.Close();
}
} |
Partager