ElasticDatasourceFactory (Moqui Framework 4.0.0)

org.moqui.impl.entity.elastic.ElasticDatasourceFactory

All Implemented Interfaces and Traits:

EntityDatasourceFactory
```
@groovy.transform.CompileStatic
class ElasticDatasourceFactory
extends java.lang.Object
implements EntityDatasourceFactory
```
To use this: 1. add a datasource under the entity-facade element in the Moqui Conf file; for example: 2. to get OrientDB to automatically create the database, add a corresponding "storage" element to the orientdb-server-config.xml file 3. add the group attribute to entity elements as needed to point them to the new datasource; for example: group="nontransactional"

Field Summary

Fields
Modifiers	Name	Description
`protected java.util.Set<java.lang.String>`	`checkedEntityIndexSet`
`protected java.lang.String`	`clusterName`
`protected MNode`	`datasourceNode`
`protected EntityFacadeImpl`	`efi`
`protected java.lang.String`	`indexPrefix`
`protected static org.slf4j.Logger`	`logger`

Properties Summary

Properties
Type	Name and description
`static java.util.Set<java.lang.String>`	`esEntityAddKeywordSet`
`static java.util.Set<java.lang.String>`	`esEntityIsKeywordSet`
`static java.util.Map<java.lang.String, java.lang.String>`	`esEntityTypeMap`

Constructor Summary

Constructors
Constructor and description
`ElasticDatasourceFactory()`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`int`	`checkAndAddAllTables()`
	`boolean`	`checkAndAddTable(java.lang.String entityName)`
	`void`	`checkCreateDocumentIndex(EntityDefinition ed)`
	`boolean`	`checkTableExists(java.lang.String entityName)`
	`static java.lang.Object`	`convertFieldValue(FieldInfo fi, java.lang.Object fValue)`
	`void`	`createBulk(java.util.List<EntityValue> valueList)`
	`void`	`destroy()`
	`jakarta.activation.DataSource`	`getDataSource()`
	`ElasticClient`	`getElasticClient()`
	`java.lang.String`	`getIndexName(EntityDefinition ed)`
	`EntityDatasourceFactory`	`init(EntityFacade ef, MNode datasourceNode)`
	`static java.util.Map`	`makeElasticEntityMapping(EntityDefinition ed)`
	`static java.util.Map`	`makeEntityFieldPropertyMap(FieldInfo fieldInfo)`
	`EntityFind`	`makeEntityFind(java.lang.String entityName)`
	`EntityValue`	`makeEntityValue(java.lang.String entityName)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#equals(java.lang.Object), java.lang.Object#getClass(), java.lang.Object#hashCode(), java.lang.Object#notify(), java.lang.Object#notifyAll(), java.lang.Object#toString(), java.lang.Object#wait(), java.lang.Object#wait(long), java.lang.Object#wait(long, int)`

- Field Detail
  - protected java.util.Set<java.lang.String> checkedEntityIndexSet
  - protected java.lang.String clusterName
  - protected MNode datasourceNode
  - protected EntityFacadeImpl efi
  - protected java.lang.String indexPrefix
  - protected static final org.slf4j.Logger logger
- Property Detail
  - static final java.util.Set<java.lang.String> esEntityAddKeywordSet
  - static final java.util.Set<java.lang.String> esEntityIsKeywordSet
  - static final java.util.Map<java.lang.String, java.lang.String> esEntityTypeMap
- Constructor Detail
  - ElasticDatasourceFactory()
- Method Detail
  - @java.lang.Override
    int checkAndAddAllTables()
  - @java.lang.Override
    boolean checkAndAddTable(java.lang.String entityName)
  - void checkCreateDocumentIndex(EntityDefinition ed)
  - @java.lang.Override
    boolean checkTableExists(java.lang.String entityName)
  - static java.lang.Object convertFieldValue(FieldInfo fi, java.lang.Object fValue)
  - @java.lang.Override
    void createBulk(java.util.List<EntityValue> valueList)
  - @java.lang.Override
    void destroy()
  - @java.lang.Override
    jakarta.activation.DataSource getDataSource()
  - ElasticClient getElasticClient()
  - java.lang.String getIndexName(EntityDefinition ed)
  - @java.lang.Override
    EntityDatasourceFactory init(EntityFacade ef, MNode datasourceNode)
  - static java.util.Map makeElasticEntityMapping(EntityDefinition ed)
  - static java.util.Map makeEntityFieldPropertyMap(FieldInfo fieldInfo)
  - @java.lang.Override
    EntityFind makeEntityFind(java.lang.String entityName)
  - @java.lang.Override
    EntityValue makeEntityValue(java.lang.String entityName)

Summary:
Field
Property
Constructor
Method

Groovy Documentation

[Groovy] Class ElasticDatasourceFactory

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected java.util.Set<java.lang.String> checkedEntityIndexSet

protected java.lang.String clusterName

protected MNode datasourceNode

protected EntityFacadeImpl efi

protected java.lang.String indexPrefix

protected static final org.slf4j.Logger logger

Property Detail

static final java.util.Set<java.lang.String> esEntityAddKeywordSet

static final java.util.Set<java.lang.String> esEntityIsKeywordSet

static final java.util.Map<java.lang.String, java.lang.String> esEntityTypeMap

Constructor Detail

ElasticDatasourceFactory()

Method Detail

@java.lang.Override
int checkAndAddAllTables()

@java.lang.Override
boolean checkAndAddTable(java.lang.String entityName)

void checkCreateDocumentIndex(EntityDefinition ed)

@java.lang.Override
boolean checkTableExists(java.lang.String entityName)

static java.lang.Object convertFieldValue(FieldInfo fi, java.lang.Object fValue)

@java.lang.Override
void createBulk(java.util.List<EntityValue> valueList)

@java.lang.Override
void destroy()

@java.lang.Override
jakarta.activation.DataSource getDataSource()

ElasticClient getElasticClient()

java.lang.String getIndexName(EntityDefinition ed)

@java.lang.Override
EntityDatasourceFactory init(EntityFacade ef, MNode datasourceNode)

static java.util.Map makeElasticEntityMapping(EntityDefinition ed)

static java.util.Map makeEntityFieldPropertyMap(FieldInfo fieldInfo)

@java.lang.Override
EntityFind makeEntityFind(java.lang.String entityName)

@java.lang.Override
EntityValue makeEntityValue(java.lang.String entityName)

[Groovy] Class ElasticDatasourceFactory

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected java.util.Set<java.lang.String> checkedEntityIndexSet

protected java.lang.String clusterName

protected MNode datasourceNode

protected EntityFacadeImpl efi

protected java.lang.String indexPrefix

protected static final org.slf4j.Logger logger

Property Detail

static final java.util.Set<java.lang.String> esEntityAddKeywordSet

static final java.util.Set<java.lang.String> esEntityIsKeywordSet

static final java.util.Map<java.lang.String, java.lang.String> esEntityTypeMap

Constructor Detail

ElasticDatasourceFactory()

Method Detail

@java.lang.Overrideint checkAndAddAllTables()

@java.lang.Overrideboolean checkAndAddTable(java.lang.String entityName)

void checkCreateDocumentIndex(EntityDefinition ed)

@java.lang.Overrideboolean checkTableExists(java.lang.String entityName)

static java.lang.Object convertFieldValue(FieldInfo fi, java.lang.Object fValue)

@java.lang.Overridevoid createBulk(java.util.List<EntityValue> valueList)

@java.lang.Overridevoid destroy()

@java.lang.Overridejakarta.activation.DataSource getDataSource()

ElasticClient getElasticClient()

java.lang.String getIndexName(EntityDefinition ed)

@java.lang.OverrideEntityDatasourceFactory init(EntityFacade ef, MNode datasourceNode)

static java.util.Map makeElasticEntityMapping(EntityDefinition ed)

static java.util.Map makeEntityFieldPropertyMap(FieldInfo fieldInfo)

@java.lang.OverrideEntityFind makeEntityFind(java.lang.String entityName)

@java.lang.OverrideEntityValue makeEntityValue(java.lang.String entityName)

@java.lang.Override
int checkAndAddAllTables()

@java.lang.Override
boolean checkAndAddTable(java.lang.String entityName)

@java.lang.Override
boolean checkTableExists(java.lang.String entityName)

@java.lang.Override
void createBulk(java.util.List<EntityValue> valueList)

@java.lang.Override
void destroy()

@java.lang.Override
jakarta.activation.DataSource getDataSource()

@java.lang.Override
EntityDatasourceFactory init(EntityFacade ef, MNode datasourceNode)

@java.lang.Override
EntityFind makeEntityFind(java.lang.String entityName)

@java.lang.Override
EntityValue makeEntityValue(java.lang.String entityName)