using?System;
using?System.Collections.Generic;
using?System.Data;
using?System.Data.SqlClient;
using?System.Text;

namespace?PinkDatabaseSync
{
????class?DBUtility?:?IDisposable
????{
????????private?string?Server;
????????private?string?Database;
????????private?string?Uid;
????????private?string?Password;
????????private?string?connectionStr;
????????private?SqlConnection?mySqlConn;

????????public?void?EnsureConnectionIsOpen（）
????????{
????????????if?（mySqlConn?==?null）
????????????{
????????????????mySqlConn?=?new?SqlConnection（this.connectionStr）;
????????????????mySqlConn.Open（）;
????????????}
????????????else?if?（mySqlConn.State?==?ConnectionState.Closed）
????????????{
????????????????mySqlConn.Open（）;
????????????}
????????}

????????public?DBUtility（string?server?string?database?string?uid?string?password）
????????{
????????????this.Server?=?server;
????????????this.Database?=?database;
????????????this.Uid?=?uid;
????????????this.Password?=?password;
????????????this.connectionStr?=?“Server=“?+?this.Server?+?“;Database=“?+?this.Database?+?“;User?Id=“?+?this.Uid?+?“;Password=“?+?this.Password;
????????}

????????public?int?ExecuteNonQueryForMultiplescripts（string?sqlStr）
????????{
????????????this.EnsureConnectionIsOpen（）;
????????????SqlCommand?cmd?=?mySqlConn.CreateCommand（）;
????????????cmd.CommandType?=?CommandType.Text;
????????????cmd.CommandText?=?sqlStr;
????????????return?cmd.ExecuteNonQuery（）;
????????}
????????public?int?ExecuteNonQuery（string?sqlStr）
????????{
????????????this.EnsureConnectionIsOpen（）;
????????????SqlCommand?cmd?=?new?SqlCommand（sqlStr?mySqlConn）;
????????????cmd.CommandType?=?CommandType.Text;
????????????return?cmd.ExecuteNonQuery（）;
????????}


????????public?object?ExecuteScalar（string?sqlStr）
????????{
????????????this.EnsureConnectionIsOpen（）;
????????????SqlCommand?cmd?=?new?SqlCommand（sqlStr?mySqlConn）;
????????????cmd.CommandType?=?CommandType.Text;
????????????return?cmd.ExecuteScalar（）;
????????}

????????public?DataSet?ExecuteDS（string?sqlStr）
????????{
????????????DataSet?ds?=?new?DataSet（）;
????????????this.EnsureConnectionIsOpen（）;
????????????SqlDataAdapter?sda?=?new?SqlDataAdapter（sqlStr?mySqlConn）;
????????????sda.Fill（ds）;
????????????return?ds;
????????}

????????public?void?BulkCopyTo（string?server?string?database?string?uid?string?password?string?tableName?string?primaryKeyName）
????????{
????????????string?connectionString?=?“Server=“?+?server?+?“;Database=“?+?database?+?“;User?Id=“?+?uid?+?“;Password=“?+?password;
????????????//?Create?destination?connection
????????????SqlConnection?destinationConnector?=?new?SqlConnection（connectionString）;

????????????SqlCommand?cmd?=?new?SqlCommand（“SELECT?*?FROM?“?+?tableName?destinationConnector）;
????????????//?Open?source?and?destination?connections.
????????????this.EnsureConnectionIsOpen（）;
????????????destinationConnector.Open（）;

????????????S