com.liferay.portal.db.partition.util

Class DBPartitionUtil

java.lang.Object

com.liferay.portal.db.partition.util.DBPartitionUtil

public class DBPartitionUtil
extends java.lang.Object

Author:

Alberto Chaparro

Constructor Summary

Constructors

Constructor and Description
DBPartitionUtil()

Method Summary

Modifier and Type	Method and Description
static boolean	addDBPartition(long companyId)
static void	checkDatabasePartitionSchemaNamePrefix()
static boolean	copyDBPartition(long fromCompanyId, long toCompanyId)
static boolean	extractDBPartition(long companyId)
static void	forEachCompanyId(com.liferay.petra.function.UnsafeConsumer<java.lang.Long,java.lang.Exception> unsafeConsumer)
static java.util.List<java.lang.String>	getConfigurationPids(long companyId)
static java.util.Map<java.lang.String,java.lang.String>	getConfigurations(long companyId)
static java.lang.String	getPartitionName(long companyId)
static boolean	insertDBPartition(long companyId)
static boolean	removeDBPartition(long companyId)
static void	replaceByTable(java.sql.Connection connection, boolean copyData, java.lang.String viewName)
static void	setDefaultCompanyId(java.sql.Connection connection)
static void	setDefaultCompanyId(long companyId)
static javax.sql.DataSource	wrapDataSource(javax.sql.DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Detail

DBPartitionUtil

public DBPartitionUtil()

Method Detail

addDBPartition

public static boolean addDBPartition(long companyId)
                              throws com.liferay.portal.kernel.exception.PortalException

Throws:

com.liferay.portal.kernel.exception.PortalException

checkDatabasePartitionSchemaNamePrefix

public static void checkDatabasePartitionSchemaNamePrefix()
                                                   throws com.liferay.portal.kernel.exception.PortalException

Throws:

com.liferay.portal.kernel.exception.PortalException

copyDBPartition

public static boolean copyDBPartition(long fromCompanyId,
                                      long toCompanyId)
                               throws com.liferay.portal.kernel.exception.PortalException

Throws:

com.liferay.portal.kernel.exception.PortalException

extractDBPartition

public static boolean extractDBPartition(long companyId)
                                  throws com.liferay.portal.kernel.exception.PortalException

Throws:

com.liferay.portal.kernel.exception.PortalException

forEachCompanyId

public static void forEachCompanyId(com.liferay.petra.function.UnsafeConsumer<java.lang.Long,java.lang.Exception> unsafeConsumer)
                             throws java.lang.Exception

Throws:

java.lang.Exception

getConfigurationPids

public static java.util.List<java.lang.String> getConfigurationPids(long companyId)
                                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getConfigurations

public static java.util.Map<java.lang.String,java.lang.String> getConfigurations(long companyId)
                                                                          throws java.sql.SQLException

Throws:

java.sql.SQLException

getPartitionName

public static java.lang.String getPartitionName(long companyId)

insertDBPartition

public static boolean insertDBPartition(long companyId)
                                 throws com.liferay.portal.kernel.exception.PortalException

Throws:

com.liferay.portal.kernel.exception.PortalException

removeDBPartition

public static boolean removeDBPartition(long companyId)
                                 throws com.liferay.portal.kernel.exception.PortalException

Throws:

com.liferay.portal.kernel.exception.PortalException

replaceByTable

public static void replaceByTable(java.sql.Connection connection,
                                  boolean copyData,
                                  java.lang.String viewName)
                           throws java.lang.Exception

Throws:

java.lang.Exception

setDefaultCompanyId

public static void setDefaultCompanyId(java.sql.Connection connection)
                                throws java.sql.SQLException

Throws:

java.sql.SQLException

setDefaultCompanyId

public static void setDefaultCompanyId(long companyId)

wrapDataSource

public static javax.sql.DataSource wrapDataSource(javax.sql.DataSource dataSource)
                                           throws java.sql.SQLException

Throws:

java.sql.SQLException