c# 读取本地数据库数据，写到远程数据库中

public void insertdata(string s1, string s2, string s3)//插入数据库
{
SqlConnection con = new SqlConnection("Data Source=10.168.1.5;Initial Catalog=data;User ID=sa;password=sa;Integrated Security=False");
con.Open();
SqlCommand cmd = new SqlCommand(string.Format("select Count(*) from newtable where a= '{0}'", s1), con);
if ((int)cmd.ExecuteScalar() > 0)
{
listBox1.Items.Add(s1 + " 数据已经存在");
}
else
{
string sql = "insert into newtable(a,b,c) values('" + s1 + "','" + s2 + "','" + s3 +"')";
cmd.CommandText = sql;
cmd.ExecuteNonQuery();
listBox1.Items.Add(s1 + " 成功添加");
}
cmd.Dispose();
con.Close();
}
int i = 0;
private void button2_Click(object sender, EventArgs e)
{
string connectionString = "Data Source=192.168.1.3;Initial Catalog=data;User ID=sa;password=sa;Integrated Security=False";
string queryString = "select aa,bb,cc from table";
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(queryString, connection);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
try
{
while (reader.Read())
{
i++;
string s0 = reader[0].ToString().Trim();
string s1 = reader[1].ToString().Trim();
string s2 = reader[2].ToString().Trim();
//入库
insertdata(s0, s1, s2);
textBox1.Text = i.ToString();
Application.DoEvents();
}
}
finally
{
command.Dispose();
connection.Close();

}
}
}