TursoSyncDatabase

CloudNimble.BlazorEssentials.TursoDb.TursoSyncDatabase

public class AppDatabase : TursoSyncDatabase
{
    public TursoDbSet<User> Users { get; }

    public AppDatabase(IJSRuntime jsRuntime) : base(jsRuntime)
    {
        Name = "app.db";
        SyncUrl = "libsql://mydb-myorg.turso.io";
        SyncAuthToken = "your-auth-token";
        Users = new TursoDbSet<User>(this);
    }
}

// Usage
await Database.ConnectAsync();
await Database.PullAsync();   // Pull changes from cloud
// ... make local changes ...
await Database.PushAsync();   // Push local changes to cloud

protected TursoDatabase(Microsoft.JSInterop.IJSRuntime jsRuntime)

public Object()

public string AuthToken { get; set; }

public bool AutoCreateSchema { get; set; }

public System.Collections.Generic.List<CloudNimble.BlazorEssentials.TursoDb.ITursoDbSet> DbSets { get; }

public bool EncryptionEnabled { get; set; }

public string EncryptionKey { get; set; }

public bool IsConnected { get; }

public bool IsSyncing { get; }

public string Name { get; init; }

public string SyncAuthToken { get; set; }

public int SyncIntervalMs { get; set; }

public bool SyncOnConnect { get; set; }

public string SyncUrl { get; set; }

public string Url { get; set; }

public System.Threading.Tasks.Task<CloudNimble.BlazorEssentials.TursoDb.TursoTransaction> BeginTransactionAsync()

await using var transaction = await Database.BeginTransactionAsync();
try
{
    await Database.Users.AddAsync(user);
    await transaction.CommitAsync();
}
catch
{
    await transaction.RollbackAsync();
    throw;
}

internal System.Threading.Tasks.Task CallJavaScriptAsync(string functionName, params object[] args)

internal System.Threading.Tasks.Task<TResult> CallJavaScriptAsync<TResult>(string functionName, params object[] args)

public System.Threading.Tasks.Task ConnectAsync()

public System.Threading.Tasks.Task ConnectAsync()

public System.Threading.Tasks.Task DisconnectAsync()

public System.Threading.Tasks.ValueTask DisposeAsync()

public System.Threading.Tasks.Task EnsureConnectedAsync()

public virtual bool Equals(object obj)

public static bool Equals(object objA, object objB)

public System.Threading.Tasks.Task<CloudNimble.BlazorEssentials.TursoDb.TursoResult> ExecuteAsync(string sql, params object[] parameters)

public System.Threading.Tasks.Task<System.Collections.Generic.List<CloudNimble.BlazorEssentials.TursoDb.TursoResult>> ExecuteBatchAsync(params (string, object[])[] statements)

public virtual int GetHashCode()

public System.Type GetType()

protected internal object MemberwiseClone()

public CloudNimble.BlazorEssentials.TursoDb.TursoPreparedStatement<TResult> Prepare<TResult>(string sql) where TResult : class, new()

public CloudNimble.BlazorEssentials.TursoDb.TursoPreparedStatement Prepare(string sql)

public System.Threading.Tasks.Task<CloudNimble.BlazorEssentials.TursoDb.TursoSyncResult> PullAsync()

public System.Threading.Tasks.Task<CloudNimble.BlazorEssentials.TursoDb.TursoSyncResult> PushAsync()

public System.Threading.Tasks.Task<System.Collections.Generic.List<T>> QueryAsync<T>(string sql, params object[] parameters)

public System.Threading.Tasks.Task<T> QuerySingleAsync<T>(string sql, params object[] parameters)

public static bool ReferenceEquals(object objA, object objB)

public System.Threading.Tasks.Task<CloudNimble.BlazorEssentials.TursoDb.TursoSyncResult> SyncAsync()

public virtual string ToString()

public System.EventHandler<CloudNimble.BlazorEssentials.TursoDb.TursoSyncResult> SyncCompleted

public System.EventHandler<System.Exception> SyncFailed

public System.EventHandler SyncStarted