Вставка значений первичного ключа с использованием SubSonic и sqlite - проблема, потому что SubSonic считает, что столбцы либо AutoIncrement, либо нет

К сожалению, похоже, что наш SQLiteDataProvider предполагает, что если это PK Int64, то он автоматически увеличивается. Я просматриваю источник прямо сейчас (я не писал этого поставщика), и я вижу, что способ загрузки схемы использует Connection.GetSchema, который использует встроенный System.Data.Common.DbConnection для получения схемы для столов.

В большинстве случаев это неоптимально, поскольку возвращает ограниченную информацию. В этом случае - он не сообщает нам, является ли столбец AUTOINCREMENT или нет. Вероятно, есть лучший способ запросить у SQLite метаинформацию в таблице, но, к сожалению, он не использовался.

Краткий ответ: определите новый ПК, если можете, и используйте другой ключ как ссылку.

Как я уже упоминал ранее, в декабре я зарегистрировал обновленный SQLiteDataProvider. Убедитесь, что в строке 407 в SQLiteDataProvider.cs у вас есть:

// Обнаружение автоинкремента теперь доступно в последней версии System.Data.SQLite. 1.0.60.0 - столбец paul.AutoIncrement = Convert.ToBoolean (row ["AUTOINCREMENT"]);

Есть также несколько других улучшений и исправлений ошибок в окружающих строках. Новый код так и не был добавлен в основной дистрибутив проекта на github, я думаю, я не слишком слежу за проектом. SQLite был прекрасным поставщиком помимо блокировки на уровне файлов. У меня есть собственная версия System.Data.SQLite, в которой используются новые функции внешнего ключа SQLite, а официальная версия должна быть выпущена в этом месяце?

Вот исправленная версия: SQLiteDataProvider.cs

Кстати, проверьте этот проект, если вам нужно конвертировать с сервера sql:

Преобразование базы данных SQL Server в базу данных SQLite http://www.codeproject.com/KB/database/convsqlservertosqlite.aspx

Я обнаружил, что не могу использовать CreateConnection, написанный как SqlDataProvider, из-за блокировки файла. CreateConnection в SQLiteDataProvider, как сейчас, неверно, поскольку игнорирует новые строки подключения.

В документе System.Data.SQLite говорится: «Вы можете создавать несколько потоков, и эти потоки могут создавать свои собственные SQLiteConnection и последующие объекты для доступа к базе данных. Множественные подключения в нескольких потоках к одному и тому же файлу базы данных вполне приемлемы и будут вести себя предсказуемо».

Итак, я попробовал следующее, и это действительно бесполезно. Используйте словарь соединений с ключом по идентификатору потока и строке соединения. Но все модульные тесты проходят, включая большинство транзакций (нужны более качественные тесты). Я написал еще пару тестов транзакций с блокировками критических секций, и я думаю, что это может быть потокобезопасным, просто нужны более реалистичные тесты.

private Dictionary<string, SQLiteConnection> threadConnectionTable = new Dictionary<string, SQLiteConnection>();

public override DbConnection CreateConnection(string newConnectionString)
{
    SQLiteConnection conn;
    string connKey = "t" + Thread.CurrentThread.ManagedThreadId + "__" + newConnectionString;
    if(threadConnectionTable.ContainsKey(connKey))
    {
        conn = threadConnectionTable[connKey];
        if(conn.State != ConnectionState.Open)
            conn.Open();
        return conn;
    }
    conn = new SQLiteConnection(newConnectionString);
    conn.Open();
    threadConnectionTable[connKey] = conn;
    return conn;
}



private Object thisLock = new Object();

[Test]
[ThreadedRepeat(10)]
public void MultiThreadRepeat()
{
    lock(thisLock)
    {
        var qcc = new QueryCommandCollection();
        int threadId = Thread.CurrentThread.ManagedThreadId;
        Debug.WriteLine("MultiThreadRepeat: thread id = " + threadId);
        int count = 0;
        for(int n = 0; n < 10; n++)
        {
            Query qry1 = new Query(Product.Schema);
            qry1.QueryType = QueryType.Update;
            qry1.AddWhere(Product.Columns.ProductID, n);
            qry1.AddUpdateSetting("ProductName", threadId + ": unit test ");
            QueryCommand cmd = qry1.BuildUpdateCommand();
            qcc.Add(cmd);
            count++;
        }
        DataService.ExecuteTransaction(qcc);
        var p1 = new Product(1);
        Assert.AreEqual(p1.ProductName, threadId + ": unit test ", StringComparison.InvariantCultureIgnoreCase);
    }

}