SQL Server CE:如果存在则更新,否则插入。

8

如果在SQL Server CE数据库表中不存在某一行,则如何进行INSERT,如果存在则进行UPDATE

我尝试了很多SQL查询,但是一直出错。这并不起作用。

IF EXISTS (SELECT * FROM Table1 WHERE Column1='SomeValue')
    UPDATE Table1 SET (...) WHERE Column1='SomeValue'
ELSE
    INSERT INTO Table1 VALUES (...)

更新:

我找到了适合我的解决方法。如果有其他好的建议,欢迎提出。

    INSERT INTO Table1 VALUES (...)
    SELECT (........)
    WHERE NOT Exists (SELECT ........)
    -- INSERT with Default value if not exist. Next, UPDATE it
    UPDATE Table1 SET (...) WHERE Column1='SomeValue'

你是否预计数据库会有并发的可能性,还是这个数据库只用于单用户应用程序? - Martin Smith
@MartinSmith,这是一个单用户移动应用程序。 - Imran Qadir Baksh - Baloch
参见:http://stackoverflow.com/questions/728373/performing-insert-or-update-upsert-on-sql-server-compact-edition - Seph
1个回答

3

我知道你已经标记了sql和sql-server-ce,但如果你愿意使用c#代码来解决这个问题.. :

对于我的移动应用程序,我使用SQL CE和C#的结果集来实现以下功能:

            // UpdateRow is a struct/class to hold the data for each row
            // SqlCeConn = connection string for db

            SqlCeCommand cmd = new SqlCeCommand("Table1", SqlCeConn);
            cmd.CommandType = CommandType.TableDirect;
            cmd.IndexName = "Column1";

            using (SqlCeResultSet rsltSet = cmd.ExecuteResultSet(ResultSetOptions.Scrollable | ResultSetOptions.Updatable))
            {
                if (UpdateRow.Column1> 0) // or != "" if it's string etc 
                {
                    if (rsltSet.Seek(DbSeekOptions.FirstEqual, UpdateRow.Column1))
                        FoundRecord = true;
                }
                rsltSet.Read();

                if (FoundRecord)
                {
                    // Update
                    rsltSet.SetInt32(1, UpdateRow.Column1);
                    rsltSet.SetInt32(2, UpdateRow.Column2);

                    // etc

                    rsltSet.Update();
                }
                else
                {
                    // Insert new record
                    SqlCeUpdatableRecord record = rsltSet.CreateRecord();
                    record.SetInt32(0, UpdateRow.Column1);
                    record.SetInt32(1, UpdateRow.Column2);

                    // etc
                    rsltSet.Insert(record, DbInsertOptions.PositionOnInsertedRow);
                }
            }
            cmd.Dispose();
        }
        catch (Exception e)
        {
            // Deal with exception

        }

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接