Aerospike LINDPad Driver

ATransaction Members

The ATransaction type exposes the following members.

Constructors


  Name Description
Public method ATransaction(ANamespaceAccess, Txn, Int32, Int32)
Initializes a new instance of ATransaction as an Aerospike transactional unit. If Commit()()()() method is not called the server will abort (rollback) this transaction.

Methods


  Name Description
Public method Abort
Abort and rollback the given multi-record transaction.

Requires server version 8.0+

Public method AsEnumerable
Returns IEnumerable>ARecord< for the records of this set based on DefaultScanPolicy or filterExpression. Note: The records' return order may vary between executions.
(Inherited from ANamespaceAccess.)
Public method BatchDelete<(Of <<'(R>)>>)
Deletes records defined in primaryKeys.
(Inherited from ANamespaceAccess.)
Public method BatchRead(IEnumerable<(Of <<'(Key>)>>), BatchPolicy, BatchReadPolicy, Expression, array<String>[]()[][], ARecord..::..DumpTypes, array<String>[]()[][])
Return a collection of [ARecord] based on primaryKeys
(Inherited from ANamespaceAccess.)
Public method BatchRead(IEnumerable<(Of <<'(ARecord>)>>), BatchPolicy, BatchReadPolicy, Expression, array<String>[]()[][], ARecord..::..DumpTypes, array<String>[]()[][])
Return a collection of [ARecord] based on records
(Inherited from ANamespaceAccess.)
Public method BatchRead<(Of <<'(P>)>>)(String, IEnumerable<(Of <<'(P>)>>), BatchPolicy, BatchReadPolicy, Expression, array<String>[]()[][], ARecord..::..DumpTypes, array<String>[]()[][])
Return a collection of ARecord based on primaryKeys
(Inherited from ANamespaceAccess.)
Public method BatchWrite<(Of <<'(P>)>>)(String, IEnumerable<(Of <<'(ValueTuple<(Of <<'(P, IEnumerable<(Of <<'(Bin>)>>)>)>>)>)>>), BatchPolicy, BatchWritePolicy, ParallelOptions)
Writes a collection of items to setName.
(Inherited from ANamespaceAccess.)
Public method BatchWrite<(Of <<'(P, V>)>>)(String, IEnumerable<(Of <<'(ValueTuple<(Of <<'(P, IDictionary<(Of <<'(String, V>)>>)>)>>)>)>>), BatchPolicy, BatchWritePolicy, ParallelOptions)
Writes a collection of items to setName.
(Inherited from ANamespaceAccess.)
Public method BatchWrite<(Of <<'(P, V>)>>)(String, IEnumerable<(Of <<'(ValueTuple<(Of <<'(P, IEnumerable<(Of <<'(ValueTuple<(Of <<'(String, V>)>>)>)>>)>)>>)>)>>), BatchPolicy, BatchWritePolicy, ParallelOptions)
Writes a collection of items to setName.
(Inherited from ANamespaceAccess.)
Public method BatchWriteObject<(Of <<'(P, T>)>>)
Writes a collection of T objects to setName.
(Inherited from ANamespaceAccess.)
Public method BatchWriteRecord<(Of <<'(R>)>>)
Writes a collection of ARecord as a operation.
(Inherited from ANamespaceAccess.)
Public method Clone
Clones the specified instance providing new policies, if provided. This will used the same transaction id as the original.
Public method Commit
Attempt to commit the given multi-record transaction. First, the expected record versions are sent to the server nodes for verification.If all nodes return success, the command is committed. Otherwise, the transaction is retried based on CommitRetries.

Requires server version 8.0+

Public method CreateTransaction
Creates an new Aerospike transaction.
Public method Equals(System.Object) (Inherited from Object.)
Public method Exists
Determines if a set exists within this namespace.
(Inherited from ANamespaceAccess.)
Public method Export
Exports all the records in this namespace to a JSON file.
(Inherited from ANamespaceAccess.)
Protected method Finalize (Inherited from Object.)
Public method FromJson(String, String, String, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>), Boolean, IList<(Of <<'(ARecord>)>>), Boolean)
Converts a Json string into an ARecord which is than put into setName. Each top-level property in the Json is translated into a bin and value. Json Arrays and embedded objects are transformed into an Aerospike List or Map<string,object>. Note: If the Json string is an Json Array, each element is treated as a separate record. If the Json string is a Json Object, the following behavior occurs: If jsonBinName is provided, the Json object is treated as an Aerospike document which will be associated with that bin. if jsonBinName is null, each json property in that Json object is treated as a separate bin/value. You can also insert individual records by calling FromJson(String, String, String, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>), Boolean, IList<(Of <<'(ARecord>)>>), Boolean).
(Inherited from ANamespaceAccess.)
Public method FromJson(String, String, Object, String, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>), Boolean)
Converts a Json string into an ARecord which is than put into setName. Each top-level property in the Json is translated into a bin and value. Json Arrays and embedded objects are transformed into an Aerospike List or Map<string,object>. Note: If jsonBinName is provided the Json item will completely be placed into this bin as its' value.
(Inherited from ANamespaceAccess.)
Public method Get
Will retrieve a record based on the primaryKey.
(Inherited from ANamespaceAccess.)
Public method GetAerospikeTxn
Gets the aerospike Txn instance or Null
Public method GetHashCode (Inherited from Object.)
Public method GetRecords(String, array<String>[]()[][])
Gets all records in a set
(Inherited from ANamespaceAccess.)
Public method GetRecords(String, String, array<String>[]()[][])
Gets all records in a namespace and/or set
(Inherited from ANamespaceAccess.)
Public method GetSetName
Gets the Aerospike Set Name based on the PK Digest.
(Inherited from ANamespaceAccess.)
Public method GetType (Inherited from Object.)
Public method Import(String, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>), Boolean, Int32, BatchPolicy, BatchWritePolicy, Boolean, CancellationToken)
Imports a Export(String, Exp, Boolean) generated JSON file into a set.
(Inherited from ANamespaceAccess.)
Public method Import(String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>), Boolean, Int32, BatchPolicy, BatchWritePolicy, Boolean, CancellationToken)
Imports a Export(String, Exp, Boolean) generated JSON file into the originally exported set.
(Inherited from ANamespaceAccess.)
Public method ImportJsonFile
This will import a Json file and convert it into a DB record for update into the DB. Each line in the file is treated as a new DB record. Each top-level property in the Json is translated into a bin and value. Json Arrays and embedded objects are transformed into an Aerospike List or Map<string,object>. Note: If the Json string is a Json Object, the following behavior occurs: If jsonBinName is provided, the Json object is treated as an Aerospike document which will be associated with that bin. if jsonBinName is null, each json property in that Json object is treated as a separate bin/value. You can also insert individual records by calling FromJson(String, String, String, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>), Boolean, IList<(Of <<'(ARecord>)>>), Boolean).
(Inherited from ANamespaceAccess.)
Protected method MemberwiseClone (Inherited from Object.)
Public method Put(ARecord, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (Writes) a DB record based on the provided record including Expiration. Note that if the namespace and/or set is different, this instances's values are used except in the case where the primary key is a digest. In these cases, an InvalidOperationException is thrown.
(Inherited from ANamespaceAccess.)
Public method Put(String, Object, String, Object, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (writes) a bin to the DB record. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method Put(String, Object, String, String, WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (writes) a bin to the DB record. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method Put(String, Object, IEnumerable<(Of <<'(Bin>)>>), WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Put (Writes) a DB record based on the provided key and bin values. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method Put<(Of <<'(V>)>>)(String, Object, IDictionary<(Of <<'(String, V>)>>), WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (Writes) a DB record based on the provided key and bin values. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method Put<(Of <<'(T>)>>)(String, Object, String, IList<(Of <<'(T>)>>), WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (writes) a bin to the DB record. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method Put<(Of <<'(T>)>>)(String, Object, String, IEnumerable<(Of <<'(T>)>>), WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (writes) a bin to the DB record. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method Put<(Of <<'(K, V>)>>)(String, Object, String, IDictionary<(Of <<'(K, V>)>>), WritePolicy, Nullable<(Of <<'(TimeSpan>)>>))
Puts (writes) a bin to the DB record. Note that if the namespace and/or set is different, this instances's values are used.
(Inherited from ANamespaceAccess.)
Public method RecordState(Key)
Returns the TransactionRecordStates of a record's key. This is only valid when the State is Active.
Public method RecordState(APrimaryKey)
Returns the TransactionRecordStates of a record's key. This is only valid when the State is Active.
Public method RecordState(ARecord)
Returns the TransactionRecordStates of a record's key. This is only valid when the State is Active.
Public method RecordState(String, Object)
Returns the TransactionRecordStates of a record's key. This is only valid when the State is Active.
Public method ToDump
Public method ToJson
Creates a Json Array of all records in the set.
(Inherited from ANamespaceAccess.)
Public method ToString
Public method Truncate(InfoPolicy, Nullable<(Of <<'(DateTime>)>>))
Truncates all the Sets in this namespace
(Inherited from ANamespaceAccess.)
Public method Truncate(String, InfoPolicy, Nullable<(Of <<'(DateTime>)>>))
Truncates the Set
(Inherited from ANamespaceAccess.)
Public method WriteObject<(Of <<'(T>)>>)
Writes the instance where each field/property is a bin name and the associated value the bin's value. and any of the "Put" methods.
(Inherited from ANamespaceAccess.)

Properties


  Name Description
Public property AbortStatus
Returns the status of the last Abort()()()() action.
Public property AerospikeConnection (Inherited from ANamespaceAccess.)
Public property BinNames
Returns all the bins used within this namespace.
(Inherited from ANamespaceAccess.)
Public property CommitRetries
Gets or sets the commit retries on certain commit exceptions/errors. It can be set up to the time of the Commit()()()(). If this value is 0, no retries are allowed and an RetryException occurred.
Public property CommitStatus
Returns the status of the last Commit()()()() action.
Public property DBPlatform
The Aerospike Platform this namespace is associated. DBPlatforms
(Inherited from ANamespaceAccess.)
Public property DefaultQueryPolicy (Inherited from ANamespaceAccess.)
Public property DefaultReadPolicy (Inherited from ANamespaceAccess.)
Public property DefaultScanPolicy (Inherited from ANamespaceAccess.)
Public property DefaultWritePolicy (Inherited from ANamespaceAccess.)
Public property IsMRT
Gets a value indicating whether this Instance has MRTs enabled.
(Inherited from ANamespaceAccess.)
Public property IsStrongConsistencyMode
Gets a value indicating whether this namespace is in strong consistency mode.
(Inherited from ANamespaceAccess.)
Public property Item
Returns the Set instance or null indicating the set doesn't exists in this namespace.
(Inherited from ANamespaceAccess.)
Public property LPnamespace (Inherited from ANamespaceAccess.)
Public property MRTTimeoutSecs
MRT timeout in seconds. The timer starts when the MRT monitor record is created. This occurs when the first command in the MRT is executed. If the timeout is reached before a commit or abort is called, the server will expire and rollback the MRT. Defaults to 10 seconds.
Public property Namespace (Inherited from ANamespaceAccess.)
Public property NullSet
Returns the Aerospike Null Set for this namespace. The Null Set will contain all the records with a namespace.
(Inherited from ANamespaceAccess.)
Public property Parent
The parent (Namespace instance, ANamespaceAccess) of this transaction. Could be a ATransaction.
Public property RetrySleepMS
Gets or sets the retry sleep in milliseconds. The sleep occurs between retries. If zero, no sleep occurs.
Public property SetNames
Gets the names of th sets associate with this namespace.
(Inherited from ANamespaceAccess.)
Public property Sets
Returns the associated set instances for this namespace.
(Inherited from ANamespaceAccess.)
Public property State
Returns the current state of the transaction.
Public property TransactionId
Returns the transaction identifier.
Public property Txn
Gets the aerospike Txn instance