Class IgniteDbConnection

Namespace

Apache.Ignite.Sql

Assembly

Apache.Ignite.dll

Ignite database connection.

public sealed class IgniteDbConnection : DbConnection, IComponent, IDbConnection, IDisposable, IAsyncDisposable

Inheritance

object

MarshalByRefObject

Component

DbConnection

IgniteDbConnection

Implements

IComponent

IDbConnection

IDisposable

IAsyncDisposable

Inherited Members

DbConnection.BeginTransaction()

DbConnection.BeginTransaction(IsolationLevel)

DbConnection.BeginTransactionAsync(IsolationLevel, CancellationToken)

DbConnection.BeginTransactionAsync(CancellationToken)

DbConnection.ChangeDatabaseAsync(string, CancellationToken)

DbConnection.CloseAsync()

DbConnection.CreateBatch()

DbConnection.CreateCommand()

DbConnection.DisposeAsync()

DbConnection.EnlistTransaction(Transaction)

DbConnection.GetSchema()

DbConnection.GetSchema(string)

DbConnection.GetSchema(string, string[])

DbConnection.GetSchemaAsync(CancellationToken)

DbConnection.GetSchemaAsync(string, CancellationToken)

DbConnection.GetSchemaAsync(string, string[], CancellationToken)

DbConnection.OpenAsync()

DbConnection.ConnectionTimeout

DbConnection.CanCreateBatch

DbConnection.StateChange

Component.Dispose()

Component.Container

Component.Site

Component.Disposed

MarshalByRefObject.GetLifetimeService()

MarshalByRefObject.InitializeLifetimeService()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

Constructors

IgniteDbConnection(string?)

Initializes a new instance of the IgniteDbConnection class.

public IgniteDbConnection(string? connectionString)

Parameters

connectionString string

Connection string.

Properties

Client

Gets the underlying Ignite client instance, or null if the connection is not open.

public IIgniteClient? Client { get; }

Property Value

IIgniteClient

ConnectionString

[AllowNull]
public override string ConnectionString { get; set; }

Property Value

string

DataSource

public override string DataSource { get; }

Property Value

string

Database

public override string Database { get; }

Property Value

string

ServerVersion

public override string ServerVersion { get; }

Property Value

string

State

public override ConnectionState State { get; }

Property Value

ConnectionState

Methods

BeginDbTransaction(IsolationLevel)

protected override DbTransaction BeginDbTransaction(IsolationLevel isolationLevel)

Parameters

isolationLevel IsolationLevel

Returns

DbTransaction

BeginDbTransactionAsync(IsolationLevel, CancellationToken)

protected override ValueTask<DbTransaction> BeginDbTransactionAsync(IsolationLevel isolationLevel, CancellationToken cancellationToken)

Parameters

isolationLevel IsolationLevel

cancellationToken CancellationToken

Returns

ValueTask<DbTransaction>

ChangeDatabase(string)

public override void ChangeDatabase(string databaseName)

Parameters

databaseName string

Close()

public override void Close()

CreateDbCommand()

protected override DbCommand CreateDbCommand()

Returns

DbCommand

Dispose(bool)

protected override void Dispose(bool disposing)

Parameters

disposing bool

Open()

public override void Open()

Open(IIgniteClient, bool)

Opens the connection using an existing Ignite client.

public void Open(IIgniteClient igniteClient, bool ownsClient = false)

Parameters

igniteClient IIgniteClient

Ignite client.

ownsClient bool

Whether to dispose the client when the connection is disposed.

OpenAsync(CancellationToken)

public override Task OpenAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

ToString()

public override string ToString()

Returns

string