Announcement

**RonnyPower** · 30.05.2004, 12:48

Nachtrag.

Die Tabellen sind in unterschiedlichen Datenbanken und diese auf unterschiedlichen Servern. Die Daten sollen von einem 6.5 auf einen 2000er kopiert werden. Im Profiler vom 2000er ist allerdings nichts davon zu sehen das irgendein Update/Insert angeschoben wird

**Andreas Kosch** · 01.06.2004, 06:12

Hallo,

f�r diese Aufgabe ist ein geklontes Recordset nicht geeeignet, da dieses ja nur eine 2. (unabh�ngige) Sichtweise (Cursor-Position) auf die Ergebnismenge einer SELECT-Abfrage bereitstellt.

Da erst in ADO.NET - aber nicht in ADO - der interne Status eines Datensatzes ge�ndert werden kann, kann erst ADO.NET die Datenmenge einer SELECT-Abfrage einer Tabelle in eine andere Tabelle einer beliebigen Datenbank als neue Datens�tze einf�gen, wenn auf die Eigenschaft AcceptChangesDuringFill zur�ckgegriffen wird.

Im Fall von ADO muss der Client die Ergebnismenge aus der Quelltabelle in einer Schleife in das Recordset f�r die Zieltabelle selbst einf�gen, indem jeder einzelne Datensatz �ber AddNew hinzugef�gt wird, um dann am St�ck �ber den UpdateBatch-Aufruf in die Zieltabelle zur�ckschreiben zu lassen

**RonnyPower** · 01.06.2004, 23:52

Hallo Herr Kosch,

danke f�r die Erkl�rung, ich hab mich das ganze Wochenende bald tod gemacht mit dem Clone. Die 'manuelle' Version hatte ich dann auch schon probiert. Funktioniert auch, allerdings ist das bei Tabellen (Report und Archiv) mit ca. 500.000 Datens�tzen eine ganz sch�n zeitaufwendige Prozedur.

Gruss Ronn

**Andreas Kosch** · 02.06.2004, 05:55

Hallo,

es spricht doch nichts dagegen, nur diese eine Funktion in ADO.NET zu implementieren (Assembly-DLL ), die von Delphi 5/6/7 dann eingebunden und aufgerufen wird.

Das folgende C#-Beispiel demonstriert das Prinzip, wobei bei Bedarf die Zieltabelle zuerst angelegt wird. Der SqlCommandBuilder generiert dann basierend auf einer SELECT-Abfrage die INSERT-/UPDATE-/DELETE-Anweisungen f�r die Zieltabelle:
<pre>
using System.Data.SqlClient;
...
private string sCREATETBL = "CREATE TABLE Customers (CustomerID nchar(5) NOT NULL, " +
"CompanyName nvarchar(40) NOT NULL,ContactName nvarchar(30) NULL, " +
"ContactTitle nvarchar(30) NULL,Address nvarchar(60) NULL,City nvarchar(15) NULL," +
"Region nvarchar(15) NULL,PostalCode nvarchar(10) NULL,Country nvarchar(15) NULL," +
"Phone nvarchar(24) NULL,Fax nvarchar(24) NULL," +
"CONSTRAINT PK_Customers PRIMARY KEY CLUSTERED (CustomerID))";
<pre>
private string sTABLENAME = "Customers";
<pre>
private bool ExistsTableInDatabase(string sDatabasename, string sTableName)
{
string sCS = string.Format("data source=localhost;initial catalog={0};integrated security=SSPI",
sDatabasename);
string sSQL = string.Format("SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_CATALOG = '{0}' AND TABLE_NAME = '{1}'",
sDatabasename, sTableName);
bool bExists = false;
SqlConnection aCon = new SqlConnection(sCS);
aCon.Open();
SqlCommand aCmd = new SqlCommand(sSQL, aCon);
try
{
bExists = (aCmd.ExecuteScalar().ToString() == sTableName) ? true : false;
}
catch (System.Exception ex)
{
MessageBox.Show(ex.Message);
}
finally
{
aCon.Close();
}
return bExists;
}
<pre>
private void ButtonTransfer_Click(object sender, System.EventArgs e)
{
string sCSFrom = string.Format("data source=localhost;initial catalog={0};integrated security=SSPI",
TextBoxFrom.Text);
string sCSTo = string.Format("data source=localhost;initial catalog={0};integrated security=SSPI",
TextBoxTo.Text);
<pre>
SqlConnection aConFrom = new SqlConnection(sCSFrom);
SqlCommand aCmdFrom = new SqlCommand("SELECT * FROM " + sTABLENAME, aConFrom);
SqlDataAdapter aAdpFrom = new SqlDataAdapter(aCmdFrom);
DataSet aDS = new DataSet();
int iRowsAffected;
aAdpFrom.AcceptChangesDuringFill = false;
<pre>
ListBox1.Items.Add("Start...");
iRowsAffected = aAdpFrom.Fill(aDS);
ListBox1.Items.Add(String.Format("... {0} Datens�tze aus {1} geladen.",
iRowsAffected.ToString(), sTABLENAME));
<pre>
SqlConnection aConTo = new SqlConnection(sCSTo);
if (ExistsTableInDatabase(TextBoxTo.Text, sTABLENAME) == false)
{
SqlCommand aDDLCmd = aConTo.CreateCommand();
aDDLCmd.CommandText = sCREATETBL;
aConTo.Open();
aDDLCmd.ExecuteNonQuery();
aConTo.Close();
ListBox1.Items.Add("... Tabelle wurde neu angelegt");
}
else
{
SqlCommand aDDLCmd = aConTo.CreateCommand();
aDDLCmd.CommandText = "TRUNCATE TABLE " + sTABLENAME;
aConTo.Open();
aDDLCmd.ExecuteNonQuery();
aConTo.Close();
ListBox1.Items.Add("... Tabelle wurde neu geleert");
}
<pre>
SqlCommand aCmdTo = new SqlCommand("SELECT * FROM " + sTABLENAME, aConTo);
SqlDataAdapter aAdpTo = new SqlDataAdapter(aCmdTo);
SqlCommandBuilder aCmdBldTo = new SqlCommandBuilder(aAdpTo);
aAdpTo = aCmdBldTo.DataAdapter;
ListBox1.Items.Add("... Verbindung zur 2. Datenbank hergestellt");
iRowsAffected = aAdpTo.Update(aDS);
ListBox1.Items.Add(String.Format("... {0} Datens�tze nach {1} kopiert.",
iRowsAffected.ToString(), sTABLENAME));
ListBox1.Items.Add("Fertig.");
StatusBar1.Text = String.Format("Es wurden {0} Datens�tze transferiert.", iRowsAffected);
}
</pre&gt

**RonnyPower** · 02.06.2004, 23:35

Hallo,

vielen Dank f�r die Hilfe. Ich habe heute noch eine andere Methode gefunden, die vom Zeitverhalten sehr sehr gut ist. Mein Problem bisher war ja die Tatsache das sich die Zieldatenbank auf einem anderen Server befand. Mittels der Systemprozedur <sp_addlinkedserver> war es mir nun m�glich den Transfer direkt �ber das SQL-Select durchzuf�hren, soda� die Daten erst gar nicht �ber ein Dataset laufen sondern direkt vom Server bearbeitet werden, wodurch sich die Transferzeit von ehemals >mdt.20 min zu ca. 1 min gesenkt hat.

Trotzdem vielen Dank f�r Ihre Hilfe

Announcement

ADO und Clone

ADO und Clone

Comment

Comment

Comment

Comment

Comment