Package org.apache.nifi.processors.standard.db.impl

Class MSSQL2008DatabaseAdapter

java.lang.Object

org.apache.nifi.processors.standard.db.impl.MSSQLDatabaseAdapter

org.apache.nifi.processors.standard.db.impl.MSSQL2008DatabaseAdapter

All Implemented Interfaces:

DatabaseAdapter

public class MSSQL2008DatabaseAdapter
extends MSSQLDatabaseAdapter

A database adapter that generates MS SQL Compatible SQL for version 2008.

Constructor Summary

Constructors

Constructor	Description
MSSQL2008DatabaseAdapter()

Method Summary

Modifier and Type	Method	Description
String	getDescription()
String	getName()
String	getSelectStatement(String tableName, String columnNames, String whereClause, String orderByClause, Long limit, Long offset)	Returns a SQL SELECT statement with the given clauses applied.
String	getSelectStatement(String tableName, String columnNames, String whereClause, String orderByClause, Long limit, Long offset, String columnForPartitioning)	Returns a SQL SELECT statement with the given clauses applied.

Methods inherited from class org.apache.nifi.processors.standard.db.impl.MSSQLDatabaseAdapter

getAlterTableStatement

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.nifi.processors.standard.db.DatabaseAdapter

generateTableName, getAutoCommitForReads, getCreateTableStatement, getInsertIgnoreStatement, getSQLForDataType, getTableAliasClause, getUpsertStatement, supportsCreateTableIfNotExists, supportsInsertIgnore, supportsUpsert

Constructor Details

MSSQL2008DatabaseAdapter

public MSSQL2008DatabaseAdapter()

Method Details

getName

public String getName()

Specified by:

getName in interface DatabaseAdapter

Overrides:

getName in class MSSQLDatabaseAdapter

getDescription

public String getDescription()

Specified by:

getDescription in interface DatabaseAdapter

Overrides:

getDescription in class MSSQLDatabaseAdapter

getSelectStatement

public String getSelectStatement(String tableName,
 String columnNames,
 String whereClause,
 String orderByClause,
 Long limit,
 Long offset)

Description copied from interface: DatabaseAdapter

Returns a SQL SELECT statement with the given clauses applied.

Specified by:

getSelectStatement in interface DatabaseAdapter

Overrides:

getSelectStatement in class MSSQLDatabaseAdapter

Parameters:

tableName - The name of the table to fetch rows from

columnNames - The names of the columns to fetch from the table

whereClause - The filter to apply to the statement. This should not include the WHERE keyword

orderByClause - The columns/clause used for ordering the result rows. This should not include the ORDER BY keywords

limit - The value for the LIMIT clause (i.e. the number of rows to return)

offset - The value for the OFFSET clause (i.e. the number of rows to skip)

Returns:

A String containing a SQL SELECT statement with the given clauses applied

getSelectStatement

public String getSelectStatement(String tableName,
 String columnNames,
 String whereClause,
 String orderByClause,
 Long limit,
 Long offset,
 String columnForPartitioning)

Description copied from interface: DatabaseAdapter

Returns a SQL SELECT statement with the given clauses applied. Note that if this method is overridden, the other overloaded methods need to be overridden as well, to call this method with columnForPartitioning = false

Specified by:

getSelectStatement in interface DatabaseAdapter

Overrides:

getSelectStatement in class MSSQLDatabaseAdapter

Parameters:

tableName - The name of the table to fetch rows from

columnNames - The names of the columns to fetch from the table

whereClause - The filter to apply to the statement. This should not include the WHERE keyword

orderByClause - The columns/clause used for ordering the result rows. This should not include the ORDER BY keywords

limit - The value for the LIMIT clause (i.e. the number of rows to return)

offset - The value for the OFFSET clause (i.e. the number of rows to skip)

columnForPartitioning - The (optional) column name that, if provided, the limit and offset values are based on values from the column itself (rather than the row number)

Returns:

A String containing a SQL SELECT statement with the given clauses applied