0

インポートしたファイルで見つかった が現在の ID に設定されているか、新しい ID であるINSERTかUPDATEに応じて実行したい機能があります (新しい場合は、「New」、「New1」とマークされます)。 、「New2」など）をファイルの列に入力します）。ProfileID.csvProfileId

残念ながら、保存プロセス中に、ProfileID. しかし、INSERTが実行されてProfileIDいる場合、これらの関数がいつ呼び出されたかは不明です。

を使用して新しい行を挿入しINSERTた後に を返すようにクエリを設定しましたが、この結果を取得して変数に入れる方法がわかりません。これを行う方法はありますか？ProfileIDSCOPE_IDENTITY()

これは保存関数のコード全体です。

private void SaveProfile(string[] curProfile)
{  
    string profId = GetValue(curProfile, (int)ProfileColumns.ProfileId).ToLower();

    string query ="";

    using (SqlConnection cn = new SqlConnection(ConfigurationManager.ConnectionStrings["AbleCommerce"].ToString()))
    {
        try
        {
            if (profId.Contains("new")) 
            {
                string insertQuery = "INSERT INTO ProductProfile (Name, Description, SpeciesLink, LineDraw, LineDrawThumbnail, ProfileThumbnail, ComponentThickness, ComponentWidth, FinishedThickness, FinishedWidth, ClassificationID, StockOrCust, ComponentFactor, Visibility, Notes, OrderBy) VALUES (@Name, @Description, @SpeciesLink, @LineDraw, @LineDrawThumbnail, @ProfileThumbnail, @ComponentThickness, @ComponentWidth, @FinishedThickness, @FinishedWidth, @ClassificationID, @StockOrCust, @ComponentFactor, @Visibility, @Notes, @OrderBy) SELECT SCOPE_IDENTITY()";
                Response.Write("PERFORM INSERT<br />");
                query = insertQuery;
            }

            {
                string updateQuery = "UPDATE ProductProfile SET Name = @Name, Description = @Description, SpeciesLink = @SpeciesLink, LineDraw = @LineDraw, LineDrawThumbnail = @LineDrawThumbnail, ProfileThumbnail = @ProfileThumbnail, ComponentThickness = @ComponentThickness, ComponentWidth = @ComponentWidth, FinishedThickness = @FinishedThickness, FinishedWidth = @FinishedWidth, ClassificationID = @ClassificationID, StockOrCust = @StockOrCust, ComponentFactor = @ComponentFactor, Visibility = @Visibility, Notes = @Notes, OrderBy = @OrderBy WHERE ProfileID = @profid";
                Response.Write("PERFORM UPDATE<br />");
                query = updateQuery;
            }

            SqlCommand cmd = new SqlCommand(query, cn);
            cmd.CommandType = CommandType.Text;

            cn.Open();

            cmd.Parameters.AddWithValue("@profid", GetValue(curProfile, (int)ProfileColumns.ProfileId).Trim());
            cmd.Parameters.AddWithValue("@Name", GetValue(curProfile, (int)ProfileColumns.Name).Trim());
            cmd.Parameters.AddWithValue("@Description", GetValue(curProfile, (int)ProfileColumns.Description).Trim());
            cmd.Parameters.AddWithValue("@SpeciesLink", GetValue(curProfile, (int)ProfileColumns.SpeciesLink).Trim());
            cmd.Parameters.AddWithValue("@Linedraw", GetValue(curProfile, (int)ProfileColumns.LineDraw).Trim());
            cmd.Parameters.AddWithValue("@LineDrawThumbnail", GetValue(curProfile, (int)ProfileColumns.LineDrawThumbnail).Trim());
            cmd.Parameters.AddWithValue("@ProfileThumbnail", GetValue(curProfile, (int)ProfileColumns.ProfileThumbnail).Trim());
            cmd.Parameters.AddWithValue("@ComponentThickness", GetValue(curProfile, (int)ProfileColumns.ComponentThickness).Trim());
            cmd.Parameters.AddWithValue("@ComponentWidth", GetValue(curProfile, (int)ProfileColumns.ComponentWidth).Trim());
            cmd.Parameters.AddWithValue("@FinishedThickness", GetValue(curProfile, (int)ProfileColumns.FinishedThickness).Trim());
            cmd.Parameters.AddWithValue("@FinishedWidth", GetValue(curProfile, (int)ProfileColumns.FinishedWidth).Trim());
            cmd.Parameters.AddWithValue("@ClassificationID", GetValue(curProfile, (int)ProfileColumns.ClassificationID).Trim());

            string stockCust = GetValue(curProfile, (int)ProfileColumns.StockOrCust).ToLower();

            switch (stockCust)
            {
                case "stock":
                    stockCust = "0";
                    break;
                case "custom":
                    stockCust = "1";
                    break;
                case "discontinued":
                    stockCust = "2";
                    break;
            }

            cmd.Parameters.AddWithValue("@StockOrCust", Convert.ToInt32(stockCust));
            cmd.Parameters.AddWithValue("@ComponentFactor", GetValue(curProfile, (int)ProfileColumns.ComponentFactor).Trim());

            string Visibility = GetValue(curProfile, (int)ProfileColumns.Visibility).ToLower();

            switch (Visibility)
            {
                case "public":
                    Visibility = "0";
                    break;
                case "private":
                    Visibility = "1";
                    break;
            }

            cmd.Parameters.AddWithValue("@Visibility", Convert.ToInt32(Visibility));
            cmd.Parameters.AddWithValue("@Notes", GetValue(curProfile, (int)ProfileColumns.Notes).Trim());
            cmd.Parameters.AddWithValue("@OrderBy", GetValue(curProfile, (int)ProfileColumns.OrderBy).Trim());

            cmd.ExecuteNonQuery();

            cn.Close();

            // this is the portion of the function that makes the call to other functions to complete the save process
            int profileID = Convert.ToInt32(GetValue(curProfile, (int)ProfileColumns.ProfileId));
            SaveArtchStyle(profileID, curProfile);
            SaveAssignedItems(profileID, curProfile);
            //update dimensions
            //UpdateProductDimensions(profileID, GetValue(curProfile, (int)ProfileColumns.FinishedThickness).Trim(), GetValue(curProfile, (int)ProfileColumns.FinishedWidth).Trim());
        }
        catch (Exception ex)
        {
            ErrorLabel.Text = "There was an error with the file." + ex.ToString();
        }
    }
}
4

2 に答える 2

4

ExecuteScalar()スコープ ID または失敗した場合は 0 を返す関数を使用します。MSDN のドキュメントと例を確認してください。

http://msdn.microsoft.com/en-us/library/system.data.sqlclient.sqlcommand.executescalar(v=vs.110).aspx 

 Int32 newProdID = 0;
 string sql =
    "INSERT INTO Production.ProductCategory (Name) VALUES (@Name); "
    + "SELECT CAST(scope_identity() AS int)";
using (SqlConnection conn = new SqlConnection(connString))
{
    SqlCommand cmd = new SqlCommand(sql, conn);
    cmd.Parameters.Add("@Name", SqlDbType.VarChar);
    cmd.Parameters["@name"].Value = newName;
    try
    {
        conn.Open();
        newProdID = (Int32)cmd.ExecuteScalar();
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
    }
}
于 2014-08-13T20:07:06.177 に答える