1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

        void CopySourceTables(List<TableNameResult> tables, int id)
        {
            // Execute the "Copy" Command on the Server for Each Table.
            using (SqlConnection conn = tgtConnStr_.CreateConnection())
            {
                conn.Open();

                int tblCount = tables.Count;
                int currTbl = 0;

                foreach (TableNameResult tbl in tables)
                {
                    RaiseOpProgressEvent(new OpEventArgs("Copying Table Data: '" + tbl.Table + "'", tblCount, currTbl += 1));

                    CopySourceTable(conn, tbl, id);
                }
            }
        }

        private void CopySourceTable(SqlConnection conn, TableNameResult tbl, int id)
        {
            using (SqlCommand comm = new SqlCommand("sp_CopySourceTableToTargetTable", conn))
            {
                comm.CommandType = CommandType.StoredProcedure;
                comm.Prepare();

                comm.Parameters.AddWithValue("@source", strConnStr_.DatabaseName);
                comm.Parameters.AddWithValue("@target", tgtConnStr_.DatabaseName);
                comm.Parameters.AddWithValue("@schema", tbl.User);
                comm.Parameters.AddWithValue("@table", tbl.Table);
                comm.Parameters.AddWithValue("@tableOID", tbl.ID);
                comm.Parameters.AddWithValue("@snapshotID", id);

                comm.ExecuteNonQuery();
            }
        }
    

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

void CopyTables(List<TableNameResult> tables, int id, bool restore)
{
    using (SqlConnection conn = tgtConnStr_.CreateConnection())
    {
        // specify the sp to use and what db's are acting as source/target.
        // obviously if we are RESTORING, the data is coming from the specified
        // "Target" (i.e. snapshot DB), so we need to swap them over.
        string spName = restore ? "sp_RestoreSnapshotTable" : "sp_CopySourceTableToTargetTable";
        string src = restore ? tgtConnStr_.DatabaseName : srcConnStr_.DatabaseName;
        string tgt = restore ? srcConnStr_.DatabaseName : tgtConnStr_.DatabaseName;

        conn.Open();

        int tblCount = tables.Count;
        int currTbl = 0;

        foreach (TableNameResult tbl in tables)
        {
            RaiseOpProgressEvent(
                new OpEventArgs("Copying Table Data: '" + tbl.Table + "'", tblCount, currTbl += 1));

            CopyTable(conn, src, tgt, tbl, id, spName);
        }
    }
}

void CopyTable(SqlConnection conn, string srcDB, string tgtDB,
    TableNameResult tbl, int snapshotID, string spName)
{
    using (SqlCommand comm = new SqlCommand(spName, conn))
    {
        comm.CommandType = CommandType.StoredProcedure;
        comm.Prepare();

        comm.Parameters.AddWithValue("@source", srcDB);
        comm.Parameters.AddWithValue("@target", tgtDB);
        comm.Parameters.AddWithValue("@schema", tbl.User);
        comm.Parameters.AddWithValue("@table", tbl.Table);
        comm.Parameters.AddWithValue("@tableOID", tbl.ID);
        comm.Parameters.AddWithValue("@snapshotID", snapshotID);

        comm.ExecuteNonQuery();
    }
}

1
2
3
4
5
6
7
8
9
10

 public Parameter parm(string str1, string str2)
    {
        comm.Parameters.Add(str1, SqlDbType.BigInt);
        comm.Parameters.Add(str2, SqlDbType.VarChar);
        con.Open();
        comm.ExecuteNonQuery();
        con.Close();
     
return??  
    }