Package org.apache.hadoop.yarn.server.federation.store.sql

Class DatabaseProduct

java.lang.Object

org.apache.hadoop.yarn.server.federation.store.sql.DatabaseProduct

@Private
public final class DatabaseProduct
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DatabaseProduct.DbType

Method Summary

Modifier and Type	Method	Description
static String	addForUpdateClause(DatabaseProduct.DbType dbType, String selectStatement)	We add for update to SQL according to different database types.
static DatabaseProduct.DbType	getDbType(Connection conn)
static boolean	isDuplicateKeyError(DatabaseProduct.DbType dbType, SQLException ex)

Methods inherited from class java.lang.Object

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

Method Details

getDbType

public static DatabaseProduct.DbType getDbType(Connection conn)
                                        throws SQLException

Throws:

SQLException

addForUpdateClause

public static String addForUpdateClause(DatabaseProduct.DbType dbType,
 String selectStatement)
                                 throws SQLException

We add for update to SQL according to different database types. This statement can ensure that a row of records in the database is only updated by one thread.

Parameters:

dbType - type of database.

selectStatement - querySQL.

Returns:

SQL after adding for update.

Throws:

SQLException - SQL exception.

isDuplicateKeyError

public static boolean isDuplicateKeyError(DatabaseProduct.DbType dbType,
 SQLException ex)