Click here to Skip to main content
15,900,816 members
Home / Discussions / Database
   

Database

 
GeneralRe: Insert Date using oledbcommand Pin
cocoonwls19-Apr-07 15:52
cocoonwls19-Apr-07 15:52 
QuestionSelect count and select Pin
N a v a n e e t h18-Apr-07 22:37
N a v a n e e t h18-Apr-07 22:37 
AnswerRe: Select count and select Pin
Pete O'Hanlon18-Apr-07 22:50
mvePete O'Hanlon18-Apr-07 22:50 
AnswerRe: Select count and select Pin
Colin Angus Mackay18-Apr-07 22:56
Colin Angus Mackay18-Apr-07 22:56 
GeneralRe: Select count and select Pin
N a v a n e e t h19-Apr-07 1:22
N a v a n e e t h19-Apr-07 1:22 
GeneralRe: Select count and select Pin
Colin Angus Mackay19-Apr-07 1:46
Colin Angus Mackay19-Apr-07 1:46 
GeneralRe: Select count and select Pin
N a v a n e e t h19-Apr-07 2:58
N a v a n e e t h19-Apr-07 2:58 
Questiondata moving Pin
tradakad18-Apr-07 22:16
tradakad18-Apr-07 22:16 
Hi, All.

example: I have two databases. mySQL and MS SQL. I have to load some data from MySQL into MS SQL.
I can't use SSIS or something like that because my version of MS SQL Server hasn't it. so I must write my pwn programm foor this task.

I write two classes - first fro working with MySQL and second for MS SQL.

----------
MySQL
----------
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using MySql.Data.MySqlClient;

public class MySqlClass
{
public MySqlClass()
{
//
// TODO: Add constructor logic here
//
}

static public MySqlConnection myConnection = null;

public string GetConnection(string con_str)
{
string connection_string = string.Empty;

if (con_str.Length == 0)
connection_string = System.Configuration.ConfigurationManager.ConnectionStrings[2].ToString();
else
connection_string = con_str;

try
{
myConnection = new MySqlConnection(connection_string);
myConnection.Open();
}
catch (MySqlException err)
{
return "Erron in connection :" + err.Message;
}

finally
{
if (myConnection != null)
myConnection.Close();
}

return null;
}

public DataSet MySqlOpen(string sql_cmd)
{
if (myConnection != null)
myConnection.Close();

myConnection.Open();

MySqlDataAdapter myDataAdapter = new MySqlDataAdapter(sql_cmd, myConnection);
DataSet myDataSet = new DataSet();

myDataAdapter.Fill(myDataSet);

myConnection.Close();

return myDataSet;

}

public void MySqlRun(string sql_cmd)
{
if (myConnection != null)
myConnection.Close();

myConnection.Open();
MySqlCommand cmd = new MySqlCommand(sql_cmd, myConnection);
cmd.ExecuteNonQuery();
myConnection.Close();

}

public void MySqlRunTransaction(string[] queries)
{
MySqlTransaction trans = null;

if (myConnection != null)
myConnection.Close();

try
{
myConnection.Open();

trans = myConnection.BeginTransaction();

MySqlCommand cmd = new MySqlCommand();

cmd.Connection = myConnection;
cmd.Transaction = trans;

foreach (string query in queries)
{
cmd.CommandText = query;
cmd.ExecuteNonQuery();
}
trans.Commit();
}
catch (MySqlException SqlErr)
{
if (trans != null)
{
trans.Rollback();
}
throw new Exception("An error occured while transaction", SqlErr);
//return;
}
finally
{
if (myConnection != null)
{
myConnection.Close();
}
}
}

}

----------

----------
MS SQL
----------
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;

public class SqlClass
{
public SqlClass()
{
//
// TODO: Add constructor logic here
//
}


static public SqlConnection myConnection = null;

public string GetConnection(string con_str)
{

string connection_string = string.Empty;

if (con_str.Length == 0)
connection_string = System.Configuration.ConfigurationManager.ConnectionStrings[3].ToString();
else
connection_string = con_str;

try
{
myConnection = new SqlConnection(connection_string);
myConnection.Open();

}
catch (SqlException err)
{
return "Erron in connection :" + err.Message;
}

finally
{
if (myConnection != null)
myConnection.Close();
}

return null;
}

public DataSet SqlOpen(string sql_cmd)
{
if (myConnection != null)
myConnection.Close();

myConnection.Open();

SqlDataAdapter myDataAdapter = new SqlDataAdapter(sql_cmd, myConnection);
DataSet myDataSet = new DataSet();

myDataAdapter.Fill(myDataSet);

myConnection.Close();

return myDataSet;

}

public void SqlRun(string sql_cmd)
{
if (myConnection != null)
myConnection.Close();

myConnection.Open();
SqlCommand cmd = new SqlCommand(sql_cmd, myConnection);
cmd.ExecuteNonQuery();
myConnection.Close();

}

public void SqlRunTransaction(string[] queries)
{
SqlTransaction trans = null;

if (myConnection != null)
myConnection.Close();

try
{
myConnection.Open();

trans = myConnection.BeginTransaction();

SqlCommand cmd = new SqlCommand();

cmd.Connection = myConnection;
cmd.Transaction = trans;

foreach (string query in queries)
{
cmd.CommandText = query;
cmd.ExecuteNonQuery();
}
trans.Commit();
}
catch (SqlException SqlErr)
{
if (trans != null)
{
trans.Rollback();
}
throw new Exception("An error occured while transaction", SqlErr);
//return;
}
finally
{
if (myConnection != null)
{
myConnection.Close();
}
}
}

}

----------

so in my main unit i declared them

public MySqlClass mys = new MySqlClass();
public SqlClass ms = new SqlClass();

and when I wanna get result from MySQL i do -

DataSet myDataSet = new DataSet();

try
{
myDataSet = mys.MySqlOpen(txtMySQLQuery.Text);
}
catch (MySqlException err)
{
Response.Write(err.ToString());
}


so I have a dataset with data (now myDataSet contains result of my query isn't ?)

my question - HOW can I load a data from this dataset into another database and table? i think I should use something like dataadapter or dataset but i'm not sure. and can I use ms.SqlRun for this (i declared it before) or I should use some another way?

thanx a lot!!!



--
"Success is simple. Do what's right, the right way, at the right time."

best regards,
tradakad

AnswerRe: data moving Pin
Colin Angus Mackay18-Apr-07 22:25
Colin Angus Mackay18-Apr-07 22:25 
GeneralRe: data moving Pin
tradakad18-Apr-07 22:47
tradakad18-Apr-07 22:47 
GeneralRe: data moving Pin
Mike Dimmick19-Apr-07 3:17
Mike Dimmick19-Apr-07 3:17 
GeneralRe: data moving Pin
Colin Angus Mackay19-Apr-07 3:25
Colin Angus Mackay19-Apr-07 3:25 
Questionupdate statement syntax error Pin
rkherath18-Apr-07 21:45
rkherath18-Apr-07 21:45 
AnswerRe: update statement syntax error Pin
Colin Angus Mackay18-Apr-07 22:24
Colin Angus Mackay18-Apr-07 22:24 
GeneralRe: update statement syntax error Pin
rkherath18-Apr-07 22:46
rkherath18-Apr-07 22:46 
Questionshow tables Pin
tradakad18-Apr-07 20:35
tradakad18-Apr-07 20:35 
AnswerRe: show tables Pin
gauthee18-Apr-07 20:55
gauthee18-Apr-07 20:55 
GeneralRe: show tables Pin
tradakad18-Apr-07 21:46
tradakad18-Apr-07 21:46 
GeneralRe: show tables Pin
gauthee18-Apr-07 22:47
gauthee18-Apr-07 22:47 
Question2-way Merge Replication(PDASql Server 2000) Pin
ayyappa4902118-Apr-07 19:41
ayyappa4902118-Apr-07 19:41 
Questionfind exact Hour and minutes..... Pin
Member 387988118-Apr-07 19:05
Member 387988118-Apr-07 19:05 
AnswerRe: find exact Hour and minutes..... Pin
Krish - KP18-Apr-07 19:28
Krish - KP18-Apr-07 19:28 
GeneralRe: find exact Hour and minutes..... Pin
Member 387988118-Apr-07 19:40
Member 387988118-Apr-07 19:40 
GeneralRe: find exact Hour and minutes..... Pin
Krish - KP18-Apr-07 20:13
Krish - KP18-Apr-07 20:13 
Questionwhen updating value repeats for all the the Columns Pin
rkherath18-Apr-07 18:03
rkherath18-Apr-07 18:03 

General General    News News    Suggestion Suggestion    Question Question    Bug Bug    Answer Answer    Joke Joke    Praise Praise    Rant Rant    Admin Admin   

Use Ctrl+Left/Right to switch messages, Ctrl+Up/Down to switch threads, Ctrl+Shift+Left/Right to switch pages.