Class Mapper
The default CQL client implementation which uses the DataStax driver ISession provided in the constructor
for running queries against a Cassandra cluster.
Assembly: Cassandra.dll
Syntax
public class Mapper : IMapper, ICqlQueryAsyncClient, ICqlWriteAsyncClient, ICqlQueryClient, ICqlWriteClient
Constructors
Mapper(ISession)
Creates a new instance of the mapper using Global mapping definitions.
Declaration
public Mapper(ISession session)
Parameters
Mapper(ISession, MappingConfiguration)
Creates a new instance of the mapper using the configuration provided
Declaration
public Mapper(ISession session, MappingConfiguration config)
Parameters
Type |
Name |
Description |
ISession |
session |
Session to be used to execute the statements
|
MappingConfiguration |
config |
Mapping definitions for the POCOs
|
Methods
ConvertCqlArgument<TValue, TDatabase>(TValue)
Allows you to convert an argument/bind variable value being used in a CQL statement using the same converters that are being used by the client
internally, including any user-defined conversions if you configured them. Will convert a value of Type TValue
to a value of
Type TDatabase
or throw an InvalidOperationException if no converter is available.
Declaration
public TDatabase ConvertCqlArgument<TValue, TDatabase>(TValue value)
Parameters
Type |
Name |
Description |
TValue |
value |
The value to convert.
|
Returns
Type |
Description |
TDatabase |
The converted value.
|
Type Parameters
Name |
Description |
TValue |
The original Type of the value.
|
TDatabase |
The Type expected by Cassandra to convert to.
|
CreateBatch()
Creates a new batch.
To set the consistency level, timestamp and other batch options, use
WithOptions(Action<CqlQueryOptions>). Individual options for each
query within the batch will be ignored.
Declaration
public ICqlBatch CreateBatch()
Returns
CreateBatch(BatchType)
Creates a new batch.
To set the consistency level, timestamp and other batch options, use
WithOptions(Action<CqlQueryOptions>). Individual options for each
query within the batch will be ignored.
Declaration
public ICqlBatch CreateBatch(BatchType batchType)
Parameters
Returns
DeleteAsync<T>(Cql)
Deletes from the table for the POCO type specified (T) using the CQL statement specified. Prepends "DELETE FROM tablename " to the CQL statement you
specify, getting the tablename appropriately from the POCO Type T.
Declaration
public Task DeleteAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
DeleteAsync<T>(string, params object[])
Deletes from the table for the POCO type specified (T) using the CQL string and bind variable values specified. Prepends "DELETE FROM tablname " to
the CQL string you specify, getting the tablename appropriately from the POCO Type T.
Declaration
public Task DeleteAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
DeleteAsync<T>(T, CqlQueryOptions)
Deletes the specified POCO from Cassandra.
Declaration
public Task DeleteAsync<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
DeleteAsync<T>(T, string, CqlQueryOptions)
Deletes the specified POCO from Cassandra using the provided execution profile.
Declaration
public Task DeleteAsync<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
DeleteIfAsync<T>(Cql)
Deletes from the table for the POCO type specified (T) using the Cql query specified.
Prepends "DELETE FROM tablename " to the CQL statement you specify, getting the tablename appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public Task<AppliedInfo<T>> DeleteIfAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
DeleteIfAsync<T>(string, params object[])
Deletes from the table for the POCO type specified (T) using the CQL string specified and query parameters specified.
Prepends "DELETE FROM tablename " to the CQL statement you specify, getting the tablename appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public Task<AppliedInfo<T>> DeleteIfAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
DeleteIf<T>(Cql)
Deletes from the table for the POCO type specified (T) using the Cql query specified.
Prepends "DELETE FROM tablename " to the CQL statement you specify, getting the tablename appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public AppliedInfo<T> DeleteIf<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
DeleteIf<T>(string, params object[])
Deletes from the table for the POCO type specified (T) using the CQL string specified and query parameters specified.
Prepends "DELETE FROM tablename " to the CQL statement you specify, getting the tablename appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public AppliedInfo<T> DeleteIf<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
Delete<T>(Cql)
Deletes from the table for the POCO type specified (T) using the CQL string specified. Prepends "DELETE FROM tablename " to the CQL statement you
specify, getting the tablename appropriately from the POCO Type T.
Declaration
public void Delete<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Type Parameters
Delete<T>(string, params object[])
Deletes from the table for the POCO type specified (T) using the CQL string and bind variable values specified. Prepends "DELETE FROM tablname " to
the CQL string you specify, getting the tablename appropriately from the POCO Type T.
Declaration
public void Delete<T>(string cql, params object[] args)
Parameters
Type Parameters
Delete<T>(T, CqlQueryOptions)
Deletes the specified POCO from Cassandra.
Declaration
public void Delete<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Type Parameters
Delete<T>(T, string, CqlQueryOptions)
Deletes the specified POCO from Cassandra using the provided execution profile.
Declaration
public void Delete<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Type Parameters
Execute(Cql)
Executes the arbitrary CQL statement specified.
Declaration
public void Execute(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Execute(ICqlBatch)
Executes the batch specfied synchronously.
Declaration
public void Execute(ICqlBatch batch)
Parameters
Remarks
Execute(ICqlBatch, string)
Executes the batch specified synchronously with the provided execution profile.
Declaration
public void Execute(ICqlBatch batch, string executionProfile)
Parameters
Remarks
Execute(string, params object[])
Executes an arbitrary CQL string with the bind variable values specified.
Declaration
public void Execute(string cql, params object[] args)
Parameters
ExecuteAsync(Cql)
Executes an arbitrary CQL statement.
Declaration
public Task ExecuteAsync(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
ExecuteAsync(ICqlBatch)
Executes the batch specified asynchronously.
Declaration
public Task ExecuteAsync(ICqlBatch batch)
Parameters
Returns
Remarks
ExecuteAsync(ICqlBatch, string)
Executes the batch specified asynchronously with the provided execution profile.
Declaration
public Task ExecuteAsync(ICqlBatch batch, string executionProfile)
Parameters
Returns
Remarks
ExecuteAsync(string, params object[])
Executes an arbitrary CQL string with the bind variable values specified.
Declaration
public Task ExecuteAsync(string cql, params object[] args)
Parameters
Returns
ExecuteConditionalAsync<T>(ICqlBatch)
Executes a batch that contains a Lightweight transaction.
Declaration
public Task<AppliedInfo<T>> ExecuteConditionalAsync<T>(ICqlBatch batch)
Parameters
Returns
Type Parameters
Remarks
ExecuteConditionalAsync<T>(ICqlBatch, string)
Executes a batch that contains a Lightweight transaction with the provided execution profile.
Declaration
public Task<AppliedInfo<T>> ExecuteConditionalAsync<T>(ICqlBatch batch, string executionProfile)
Parameters
Returns
Type Parameters
Remarks
ExecuteConditional<T>(ICqlBatch)
Executes a batch that contains a Lightweight transaction.
Declaration
public AppliedInfo<T> ExecuteConditional<T>(ICqlBatch batch)
Parameters
Returns
Type Parameters
Remarks
ExecuteConditional<T>(ICqlBatch, string)
Executes a batch that contains a Lightweight transaction.
Declaration
public AppliedInfo<T> ExecuteConditional<T>(ICqlBatch batch, string executionProfile)
Parameters
Returns
Type Parameters
Remarks
FetchAsync<T>(Cql)
Gets a list of T from Cassandra using the CQL statement specified.
Declaration
public Task<IEnumerable<T>> FetchAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
FetchAsync<T>(CqlQueryOptions)
Gets a list of all T from Cassandra.
Declaration
public Task<IEnumerable<T>> FetchAsync<T>(CqlQueryOptions options = null)
Parameters
Returns
Type Parameters
FetchAsync<T>(string, params object[])
Gets a list of T from Cassandra using the CQL statement and parameter values specified.
Declaration
public Task<IEnumerable<T>> FetchAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
FetchPageAsync<T>(Cql)
Gets a paged list of T results from Cassandra.
Suitable for manually page through all the results of a query.
Declaration
public Task<IPage<T>> FetchPageAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
FetchPageAsync<T>(CqlQueryOptions)
Gets a paged list of T results from Cassandra using the CQL statement specified.
Suitable for manually page through all the results of a query.
Declaration
public Task<IPage<T>> FetchPageAsync<T>(CqlQueryOptions options = null)
Parameters
Returns
Type Parameters
FetchPageAsync<T>(int, byte[], string, object[])
Gets a paged list of T results from Cassandra.
Suitable for manually page through all the results of a query.
Declaration
public Task<IPage<T>> FetchPageAsync<T>(int pageSize, byte[] pagingState, string query, object[] args)
Parameters
Type |
Name |
Description |
int |
pageSize |
Amount of items to return
|
byte[] |
pagingState |
The token representing the state of the result page. To get the first page, use a null value.
|
string |
query |
Cql query
|
object[] |
args |
Query parameters
|
Returns
Type Parameters
FetchPage<T>(Cql)
Gets a paged list of T results from Cassandra.
Suitable for manually page through all the results of a query.
Declaration
public IPage<T> FetchPage<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type |
Description |
IPage<T> |
|
Type Parameters
FetchPage<T>(CqlQueryOptions)
Gets a paged list of T results from Cassandra using the CQL statement specified.
Suitable for manually page through all the results of a query.
Declaration
public IPage<T> FetchPage<T>(CqlQueryOptions queryOptions = null)
Parameters
Returns
Type |
Description |
IPage<T> |
|
Type Parameters
FetchPage<T>(int, byte[], string, params object[])
Gets a paged list of T results from Cassandra.
Suitable for manually page through all the results of a query.
Declaration
public IPage<T> FetchPage<T>(int pageSize, byte[] pagingState, string cql, params object[] args)
Parameters
Type |
Name |
Description |
int |
pageSize |
Amount of items to return
|
byte[] |
pagingState |
The token representing the state of the result page. To get the first page, use a null value.
|
string |
cql |
|
object[] |
args |
Query parameters
|
Returns
Type |
Description |
IPage<T> |
|
Type Parameters
Fetch<T>(Cql)
Gets a list of T from Cassandra using the CQL statement specified.
Declaration
public IEnumerable<T> Fetch<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
Fetch<T>(CqlQueryOptions)
Gets a list of all T from Cassandra.
Declaration
public IEnumerable<T> Fetch<T>(CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
Fetch<T>(string, params object[])
Gets a list of T from Cassandra using the CQL statement and parameter values specified.
Declaration
public IEnumerable<T> Fetch<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
FirstAsync<T>(Cql)
Gets the first T from Cassandra using the CQL specified. Will throw if no records are returned.
Declaration
public Task<T> FirstAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
FirstAsync<T>(string, params object[])
Gets the first T from Cassandra using the CQL statement and parameter values specified. Will throw if no
records are returned.
Declaration
public Task<T> FirstAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
FirstOrDefaultAsync<T>(Cql)
Gets the first T from Cassandra using the CQL specified. Will return the default value of T if no records
are found.
Declaration
public Task<T> FirstOrDefaultAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
FirstOrDefaultAsync<T>(string, params object[])
Gets the first T from Cassandra using the CQL statement and parameter values specified. Will return the
default value of T is no records are found.
Declaration
public Task<T> FirstOrDefaultAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
FirstOrDefault<T>(Cql)
Gets the first T from Cassandra using the CQL statement specified. Will return the default value of T if
no records are found.
Declaration
public T FirstOrDefault<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
FirstOrDefault<T>(string, params object[])
Gets the first T from Cassandra using the CQL statement and parameter values specified. Will return the
default value of T is no records are found.
Declaration
public T FirstOrDefault<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
First<T>(Cql)
Gets the first T from Cassandra using the CQL statement specified. Will throw if no records are returned.
Declaration
public T First<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
First<T>(string, params object[])
Gets the first T from Cassandra using the CQL statement and parameter values specified. Will throw if no
records are returned.
Declaration
public T First<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
InsertAsync<T>(T, CqlQueryOptions)
Inserts the specified POCO in Cassandra.
Declaration
public Task InsertAsync<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
InsertAsync<T>(T, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra.
Declaration
public Task InsertAsync<T>(T poco, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertAsync<T>(T, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra.
Declaration
public Task InsertAsync<T>(T poco, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertAsync<T>(T, string, CqlQueryOptions)
Inserts the specified POCO in Cassandra using the provided execution profile.
Declaration
public Task InsertAsync<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
InsertAsync<T>(T, string, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra using the provided execution profile.
Declaration
public Task InsertAsync<T>(T poco, string executionProfile, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertAsync<T>(T, string, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra using the provided execution profile.
Declaration
public Task InsertAsync<T>(T poco, string executionProfile, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExistsAsync<T>(T, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public Task<AppliedInfo<T>> InsertIfNotExistsAsync<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
InsertIfNotExistsAsync<T>(T, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists.
Declaration
public Task<AppliedInfo<T>> InsertIfNotExistsAsync<T>(T poco, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExistsAsync<T>(T, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists.
Declaration
public Task<AppliedInfo<T>> InsertIfNotExistsAsync<T>(T poco, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExistsAsync<T>(T, string, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists, with the provided execution profile.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public Task<AppliedInfo<T>> InsertIfNotExistsAsync<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
InsertIfNotExistsAsync<T>(T, string, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists, with the provided execution profile.
Declaration
public Task<AppliedInfo<T>> InsertIfNotExistsAsync<T>(T poco, string executionProfile, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExistsAsync<T>(T, string, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists, with the provided execution profile.
Declaration
public Task<AppliedInfo<T>> InsertIfNotExistsAsync<T>(T poco, string executionProfile, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExists<T>(T, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public AppliedInfo<T> InsertIfNotExists<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
InsertIfNotExists<T>(T, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists.
Declaration
public AppliedInfo<T> InsertIfNotExists<T>(T poco, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExists<T>(T, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists.
Declaration
public AppliedInfo<T> InsertIfNotExists<T>(T poco, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExists<T>(T, string, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists, with the provided execution profile.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public AppliedInfo<T> InsertIfNotExists<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
InsertIfNotExists<T>(T, string, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists, with the provided execution profile.
Declaration
public AppliedInfo<T> InsertIfNotExists<T>(T poco, string executionProfile, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
InsertIfNotExists<T>(T, string, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra, if not exists, with the provided execution profile.
Declaration
public AppliedInfo<T> InsertIfNotExists<T>(T poco, string executionProfile, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Returns
Type Parameters
Insert<T>(T, CqlQueryOptions)
Inserts the specified POCO in Cassandra.
Declaration
public void Insert<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Type Parameters
Insert<T>(T, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra.
Declaration
public void Insert<T>(T poco, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Type Parameters
Insert<T>(T, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra.
Declaration
public void Insert<T>(T poco, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Type Parameters
Insert<T>(T, string, CqlQueryOptions)
Inserts the specified POCO in Cassandra using the provided execution profile.
Declaration
public void Insert<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Type Parameters
Insert<T>(T, string, bool, CqlQueryOptions)
Inserts the specified POCO in Cassandra using the provided execution profile.
Declaration
public void Insert<T>(T poco, string executionProfile, bool insertNulls, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Type Parameters
Insert<T>(T, string, bool, int?, CqlQueryOptions)
Inserts the specified POCO in Cassandra using the provided execution profile.
Declaration
public void Insert<T>(T poco, string executionProfile, bool insertNulls, int? ttl, CqlQueryOptions queryOptions = null)
Parameters
Type |
Name |
Description |
T |
poco |
The POCO instance
|
string |
executionProfile |
The execution profile to use when executing the request.
|
bool |
insertNulls |
Determines if the query must be generated using NULL values for null POCO
members.
Use false if you don't want to consider null values for the INSERT
operation (recommended).
Use true if you want to override all the values in the table,
generating tombstones for null values.
|
int? |
ttl |
Time to live (in seconds) for the inserted values. If set, the inserted values are automatically removed
from the database after the specified time.
|
CqlQueryOptions |
queryOptions |
Optional query options
|
Type Parameters
SingleAsync<T>(Cql)
Gets a single T from Cassandra using the CQL statement specified. Will throw if no records or more than one
record is returned.
Declaration
public Task<T> SingleAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
SingleAsync<T>(string, params object[])
Gets a single T from Cassandra using the CQL statement and parameter values specified. Will throw if
no records or more than one record is returned.
Declaration
public Task<T> SingleAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
SingleOrDefaultAsync<T>(Cql)
Gets a single T from Cassandra using the CQL statement specified. Will return the default value of T if no
records are found. Will throw if more than one record is returned.
Declaration
public Task<T> SingleOrDefaultAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
SingleOrDefaultAsync<T>(string, params object[])
Gets a single T from Cassandra using the CQL statement and parameter values specified. Will return the
default value of T if no records are found. Will throw if more than one record is returned.
Declaration
public Task<T> SingleOrDefaultAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
SingleOrDefault<T>(Cql)
Gets a single T from Cassandra using the CQL statement specified. Will return the default value of T if
no records are found. Will throw if more than one record is returned.
Declaration
public T SingleOrDefault<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
SingleOrDefault<T>(string, params object[])
Gets a single T from Cassandra using the CQL statement and parameter values specified. Will return the
default value of T if no records are found. Will throw if more than one record is returned.
Declaration
public T SingleOrDefault<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
Single<T>(Cql)
Gets a single T from Cassandra using the CQL statement specified. Will throw if no records or more than
one record is returned.
Declaration
public T Single<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
Single<T>(string, params object[])
Gets a single T from Cassandra using the CQL statement and parameter values specified. Will throw if
no records or more than one record is returned.
Declaration
public T Single<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
UpdateAsync<T>(Cql)
Updates the table for the poco type specified (T) using the CQL statement specified. Prepends "UPDATE tablename" to the CQL statement you specify,
getting the tablename appropriately from the POCO Type T.
Declaration
public Task UpdateAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
UpdateAsync<T>(string, params object[])
Updates the table for the POCO type specified (T) using the CQL string and bind variable values specified. Prepends "UPDATE tablename " to the CQL
string you specify, getting the tablename appropriately from the POCO Type T.
Declaration
public Task UpdateAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
Name |
Description |
T |
The POCO Type being updated.
|
UpdateAsync<T>(T, CqlQueryOptions)
Updates the POCO specified in Cassandra.
Declaration
public Task UpdateAsync<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
UpdateAsync<T>(T, string, CqlQueryOptions)
Updates the POCO specified in Cassandra using the provided execution profile.
Declaration
public Task UpdateAsync<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Returns
Type Parameters
UpdateIfAsync<T>(Cql)
Updates the table for the poco type specified (T) using the CQL statement specified, using lightweight transactions.
Prepends "UPDATE tablename" to the CQL statement you specify, getting the table name appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public Task<AppliedInfo<T>> UpdateIfAsync<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
UpdateIfAsync<T>(string, params object[])
Updates the table for the poco type specified (T) using the CQL statement specified, using lightweight transactions.
Prepends "UPDATE tablename" to the CQL statement you specify, getting the table name appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public Task<AppliedInfo<T>> UpdateIfAsync<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
UpdateIf<T>(Cql)
Updates the table for the poco type specified (T) using the CQL statement specified, using lightweight transactions.
Prepends "UPDATE tablename" to the CQL statement you specify, getting the table name appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public AppliedInfo<T> UpdateIf<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Returns
Type Parameters
UpdateIf<T>(string, params object[])
Updates the table for the poco type specified (T) using the CQL statement specified, using lightweight transactions.
Prepends "UPDATE tablename" to the CQL statement you specify, getting the table name appropriately from the POCO Type T.
Returns information whether it was applied or not. If it was not applied, it returns details of the existing values.
Declaration
public AppliedInfo<T> UpdateIf<T>(string cql, params object[] args)
Parameters
Returns
Type Parameters
Update<T>(Cql)
Updates the table for the POCO type specified (T) using the CQL statement specified. Prepends "UPDATE tablename" to the CQL statement you specify,
getting the tablename appropriately from the POCO Type T.
Declaration
public void Update<T>(Cql cql)
Parameters
Type |
Name |
Description |
Cql |
cql |
|
Type Parameters
Update<T>(string, params object[])
Updates the table for the POCO type specified (T) using the CQL string and bind variable values specified. Prepends "UPDATE tablename " to the CQL
string you specify, getting the tablename appropriately from the POCO Type T.
Declaration
public void Update<T>(string cql, params object[] args)
Parameters
Type Parameters
Name |
Description |
T |
The POCO Type being updated.
|
Update<T>(T, CqlQueryOptions)
Updates the POCO specified in Cassandra.
Declaration
public void Update<T>(T poco, CqlQueryOptions queryOptions = null)
Parameters
Type Parameters
Update<T>(T, string, CqlQueryOptions)
Updates the POCO specified in Cassandra using the provided execution profile.
Declaration
public void Update<T>(T poco, string executionProfile, CqlQueryOptions queryOptions = null)
Parameters
Type Parameters
Implements
See Also