Oncelikle MS SQL server'a aktarım için SqlBulkCopy class kullanıniz. SqlBulkCopy ile gercek tabloya degil, gecici bir tabloya yukleyiniz. Sonra, gercek tablonuza o gecici tablodan NOT EXISTS kullanarak aktariniz. Asagida bir ornek var, eskiden yazilmis bir
ornek oldugundan alan adlari, tablo adalri sizinkiyle ayni degil ama ne yapildigi belli:
void Main()
{
string sqlConnectionString = @"server=.\SQLExpress;Trusted_Connection=yes;Database=Test";
string path = @"d:\Temp\Customers.xlsx"; // Northwind.mdb'den export edilmis ornek excel sheet
string sheetName = "Customers$";
DataTable tbl = new DataTable(); // sadece sonuclari gostermek icin
using (OleDbConnection cn = new OleDbConnection(
"Provider=Microsoft.ACE.OLEDB.12.0;Data Source="+path+
";Extended Properties=\"Excel 8.0;HDR=Yes\""))
using (SqlConnection scn = new SqlConnection( sqlConnectionString ))
{
// gecici bir SQL server tablosu yaratiyoruz ornek icin.
// tablo zaten var ise bu kisim olmayacak. Sadece insert edecektik.
SqlCommand createTemp = new SqlCommand();
createTemp.CommandText = @"create table #SqlBulkOrnek
(
[MusteriId] char(6),
[Sirket] varchar(50),
[IlgiliKisi] varchar(50),
[Ulke] varchar(20)
)";
createTemp.Connection = scn;
scn.Open();
createTemp.ExecuteNonQuery();
// Excelden veriyi al ve SqlBulkCopy ile servera yaz
OleDbCommand cmd = new OleDbCommand(String.Format("select * from [{0}]",sheetName), cn);
SqlBulkCopy sbc = new SqlBulkCopy(scn, SqlBulkCopyOptions.TableLock,null);
// Excel dosyasindaki kolonlar ile SQL serverdaki kolonlar farkli
// Exceldeki ilk kolon SQL server tablomuzdaki MusteriId, 2. Sirket
// 3. IlgiliKisi ve 9. excel kolonu Ulke olacak sekilde Mapping ekliyoruz
// Mapping olmasa idi ayni yapidaki veri kopyalaniyor olacakti.
sbc.ColumnMappings.Add(0,"[MusteriId]");
sbc.ColumnMappings.Add(1,"[Sirket]");
sbc.ColumnMappings.Add(2,"[IlgiliKisi]");
sbc.ColumnMappings.Add(8,"[Ulke]");
cn.Open();
OleDbDataReader rdr = cmd.ExecuteReader();
// SqlBulkCopy'nin propertyleri
sbc.NotifyAfter = 100000;
sbc.BatchSize = 1000;
sbc.BulkCopyTimeout = 10000;
sbc.DestinationTableName = "##SqlBulkOrnek";
// Arada notification
sbc.SqlRowsCopied += (sender,e) =>
{
Console.WriteLine("-- Copied {0} rows to {1}.",
e.RowsCopied,
((SqlBulkCopy)sender).DestinationTableName);
};
// server'a yaz
sbc.WriteToServer(rdr);
if (!rdr.IsClosed) { rdr.Close(); }
cn.Close();
// Server'a hakikaten yazildigini kontrol ediyoruz.
// Bu sadece ornekte test icin.
// Oku
SqlCommand cmdRead = new SqlCommand("select * from #SqlBulkOrnek", scn);
tbl.Load(cmdRead.ExecuteReader());
// Aktarım örneği
new SqlCommand(@"insert into hedefTablo
(MusteriId, Sirket, IlgiliKisi, Ulke)
select MusteriId, Sirket, IlgiliKisi, Ulke
from #SqlBulkOrnek
where not exists (select musteriId from hedefTablo)", scn).ExecuteNonQuery();
scn.Close();
}
// Serverdan okunanlari bir formda goster.
Form f = new Form();
DataGridView dgv = new DataGridView();
dgv.Location = new Point(0, 0);
dgv.Dock = DockStyle.Fill;
dgv.DataSource = tbl;
f.Controls.Add(dgv);
f.ClientSize = new Size(1024, 768);
f.ShowDialog();
}
Not: Tabii tablonuzdaki Primary Key muhtemelen o siparis kodudur, ya da unique indexlenmistir ve veritabani insert etmenizi engeller ama o zaman tek tek insert deneyip hata kontrolu yapmaniz gerekir. Onun yerine, bu sekilde indexe guvenmeden yapmis olursunuz.
Blog
How to create a Minimal, Reproducible Example
The way to Go.
World's most advanced open source (object-) relational
Database.
Flutter (for mobile, for web & desktop.
Not: Temelin geri zekali arkadasi
Idris bu mesaja da atlayip ne kadar aptal oldugunu bir kez daha belgeleyebilir. Kendisinin tek marifeti beni takip edip, neden her soruya cevap verdigimi, yardim etmeye calistigimi sorgulamaktir. Bu beyinsiz zavalliya,
aptal oldugunu hatirlatmayi unutmayiniz.
