sqlite - 使用 F# & SQLite.Net.Async PCL 创建数据库表

Question

我正在尝试使用 C# Windows 8 应用程序中的 F# 项目创建一个表“ Material ”。这可能在库(SQLite.Net.Async)上更具体，但我没有太多运气让它工作。我明白了，“)”附近的错误:语法错误，这没有帮助，如果我能看到它试图执行的完整 SQL 查询，我可能会进一步解决这个问题。

Sql.fsi

namespace DataAccess

open SQLite.Net.Async
open SQLite.Net.Interop
open System.Threading.Tasks

module Sql =
    val connect : ISQLitePlatform -> string -> SQLiteAsyncConnection
    val initTables : SQLiteAsyncConnection -> Task<SQLiteAsyncConnection.CreateTablesResult> option

Sql.fs

namespace DataAccess

open SQLite
open SQLite.Net
open SQLite.Net.Async
open SQLite.Net.Attributes
open System
open System.Threading.Tasks

module Sql =
    [<Table(name="Materials")>]
    type Material (id : int, name : string) = 
        let mutable m_id : int = id
        let mutable m_name : string = name

        new() = Material(0, null)

        [<Column(name="Id")>] [<PrimaryKey>] [<AutoIncrement>]
        member this.Id
            with get() = m_id
            and set(value) = m_id <- value

        [<Column(name="Name")>]
        member this.Name
            with get() = m_name
            and set(value) = m_name <- value

        override this.ToString() = System.String.Format("[{0}] {1}", m_id, m_name)

    let connect (platform : SQLite.Net.Interop.ISQLitePlatform) (databasePath : string) : SQLiteAsyncConnection =
        let connectionString = SQLiteConnectionString(databasePath, false)
        let connectionFactory = new Func<SQLiteConnectionWithLock>(fun () -> new SQLiteConnectionWithLock(platform, connectionString));
        let connection = new SQLiteAsyncConnection(connectionFactory)
        connection

    let initTables (connection : SQLiteAsyncConnection) : Task<SQLiteAsyncConnection.CreateTablesResult> option =
        try
            let result = connection.CreateTableAsync<Material>()
            Some(result)
        with
            | :? SQLite.Net.SQLiteException->
            None

集线器.cs

    async private void StackPanel_Tapped(object sender, TappedRoutedEventArgs e)
    {
        await GetDB();
    }

然后是异常(exception):

An exception of type 'SQLite.Net.SQLiteException' occurred in mscorlib.dll but was not handled in user code

Additional information: near ")": syntax error

"  at SQLite.Net.Platform.WinRT.SQLiteApiWinRT.Prepare2(IDbHandle db, String query)
   at SQLite.Net.SQLiteCommand.Prepare()
   at SQLite.Net.SQLiteCommand.ExecuteNonQuery()
   at SQLite.Net.SQLiteConnection.Execute(String query, Object[] args)
   at SQLite.Net.SQLiteConnection.CreateTable(Type ty, CreateFlags createFlags)
   at SQLite.Net.Async.SQLiteAsyncConnection.<>c__DisplayClass0.<CreateTablesAsync>b__1()
   at System.Threading.Tasks.Task`1.InnerInvoke()
   at System.Threading.Tasks.Task.Execute()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
   at App1.HubPage1.<GetDB>d__0.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
   at App1.HubPage1.<StackPanel_Tapped>d__9.MoveNext()"

Answer 1

我能够弄清楚这个问题。这是我的 FSharp 签名 文件缺少“ Material ”定义。

Sql.fsi

namespace DataAccess

open SQLite.Net.Async
open SQLite.Net.Interop
open System.Threading.Tasks

module Sql =
    type Material =
        new : unit -> Material
        new : id:int * name:string -> Material
        member Id : int
        member Name : string
    val connect : ISQLitePlatform -> string -> SQLiteAsyncConnection
    val initTables : SQLiteAsyncConnection -> Task<SQLiteAsyncConnection.CreateTablesResult>

Sql.fs

namespace DataAccess

open SQLite
open SQLite.Net
open SQLite.Net.Async
open SQLite.Net.Attributes
open System
open System.Threading.Tasks

module Sql =
    type Material (id : int, name : string) = 
        let mutable m_id : int = id
        let mutable m_name : string = name

        new() = Material(0, null)

        [<PrimaryKey>] [<AutoIncrement>]
        member this.Id
            with get() = m_id
            and set(value) = m_id <- value

        member this.Name
            with get() = m_name
            and set(value) = m_name <- value

        override this.ToString() = System.String.Format("[{0}] {1}", m_id, m_name)

    let connect (platform : SQLite.Net.Interop.ISQLitePlatform) (databasePath : string) : SQLiteAsyncConnection =
        let connectionString = SQLiteConnectionString(databasePath, false)
        let connectionFactory = new Func<SQLiteConnectionWithLock>(fun () -> new SQLiteConnectionWithLock(platform, connectionString));
        let connection = new SQLiteAsyncConnection(connectionFactory)
        connection

    let initTables (connection : SQLiteAsyncConnection) : Task<SQLiteAsyncConnection.CreateTablesResult> =
        connection.CreateTableAsync<Material>()

集线器.cs

async public void GetDB()
{
    StorageFolder localFolder = ApplicationData.Current.LocalFolder;
    var file = await localFolder.CreateFileAsync("test.db", CreationCollisionOption.OpenIfExists);
    var filePath = file.Path;
    var connection = Sql.connect(new SQLitePlatformWinRT(), filePath);

    var result = await Sql.initTables(connection);
}