MysqlRepository (molgenis-data-mysql 1.6.0 API)

java.lang.Object
- org.molgenis.data.support.AbstractRepository
- - org.molgenis.data.mysql.MysqlRepository

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Entity>, Manageable, Repository
```
public class MysqlRepository
extends AbstractRepository
implements Manageable
```

Field Summary

Fields
Modifier and Type Field and Description

static int BATCH_SIZE

Fields
Modifier and Type	Field and Description
`static int`	`BATCH_SIZE`

Constructor Summary

Constructors
Constructor and Description
`MysqlRepository(DataService dataService, DataSource dataSource, AsyncJdbcTemplate asyncJdbcTemplate)` Creates a new MysqlRepository.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`add(Entity entity)`
`Integer`	`add(Iterable<? extends Entity> entities)`
`protected void`	`addAttribute(AttributeMetaData attributeMetaData)` Adds an attribute to the repository.
`protected void`	`addAttributeSync(AttributeMetaData attributeMetaData)` Adds an attribute to the repository.
`void`	`addAttributeToTable(String attributeName)` Adds an attribute to the table for this entity.
`long`	`count(Query q)`
`void`	`create()`
`boolean`	`createTableIfNotExists()` Creates the table for this repository if it does not already exist.
`void`	`delete(Entity entity)`
`void`	`delete(Iterable<? extends Entity> entities)`
`void`	`deleteAll()`
`void`	`deleteById(Iterable<Object> ids)`
`void`	`deleteById(Object id)`
`void`	`drop()`
`void`	`dropAttribute(String attributeName)`
`Iterable<Entity>`	`findAll(Iterable<Object> ids)`
`Iterable<Entity>`	`findAll(Query q)`
`Entity`	`findOne(Object id)`
`Entity`	`findOne(Query q)`
`String`	`getAlterSql(AttributeMetaData attributeMetaData)`
`Set<RepositoryCapability>`	`getCapabilities()`
`protected String`	`getCountSql(Query q, List<Object> parameters)`
`protected String`	`getCreateFKeySql(AttributeMetaData att)`
`protected String`	`getCreateSql()`
`String`	`getDeleteSql()`
`protected String`	`getDropSql()`
`EntityMetaData`	`getEntityMetaData()`
`protected String`	`getFromSql(Query q)`
`protected String`	`getInsertSql()`
`protected String`	`getMrefCreateSql(AttributeMetaData att)`
`protected String`	`getSelectSql(Query q, List<Object> parameters)`
`protected String`	`getSortSql(Query q)`
`protected String`	`getUniqueSql(AttributeMetaData att)`
`protected String`	`getUpdateSql()`
`protected String`	`getWhereSql(Query q, List<Object> parameters, int mrefFilterIndex)`
`Iterator<Entity>`	`iterator()`
`void`	`setMetaData(EntityMetaData metaData)`
`boolean`	`tableExists()`
`void`	`update(Entity entity)`
`void`	`update(Iterable<? extends Entity> entities)`

Methods inherited from class org.molgenis.data.support.AbstractRepository
aggregate, clearCache, close, count, flush, getName, query

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.molgenis.data.Repository
aggregate, clearCache, count, flush, getName, query

Methods inherited from interface java.lang.Iterable
forEach, spliterator

Methods inherited from interface java.io.Closeable
close

- Field Detail
  - BATCH_SIZE
```
public static final int BATCH_SIZE
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - MysqlRepository
```
public MysqlRepository(DataService dataService,
                       DataSource dataSource,
                       AsyncJdbcTemplate asyncJdbcTemplate)
```
    Creates a new MysqlRepository.
    
    Parameters:
    
    dataSource - the datasource to use to execute statements on the Mysql database
    
    asyncJdbcTemplate - AsyncJdbcTemplate to use to execute DDL statements in an isolated transaction on the Mysql database
- Method Detail
  - setMetaData
```
public void setMetaData(EntityMetaData metaData)
```
  - drop
```
public void drop()
```
    Specified by:
    
    drop in interface Manageable
  - dropAttribute
```
public void dropAttribute(String attributeName)
```
  - getDropSql
```
protected String getDropSql()
```
  - create
```
public void create()
```
    Specified by:
    
    create in interface Manageable
  - addAttribute
```
protected void addAttribute(AttributeMetaData attributeMetaData)
```
    Adds an attribute to the repository. Will execute the alter table statement in a different thread so that the current transaction does not get committed. This is needed for adding columns during an import.
    
    Parameters:
    
    attributeMetaData - the AttributeMetaData to add
  - addAttributeSync
```
protected void addAttributeSync(AttributeMetaData attributeMetaData)
```
    Adds an attribute to the repository. Will excecute the alter table statement in the current thread. Please note that this *will* commit any existing transactions. This is needed for adding columns in the annotator.
    
    Parameters:
    
    attributeMetaData - the AttributeMetaData to add
  - getMrefCreateSql
```
protected String getMrefCreateSql(AttributeMetaData att)
                           throws MolgenisModelException
```
    Throws:
    
    MolgenisModelException
  - getCreateSql
```
protected String getCreateSql()
                       throws MolgenisModelException
```
    Throws:
    
    MolgenisModelException
  - getAlterSql
```
public String getAlterSql(AttributeMetaData attributeMetaData)
                   throws MolgenisModelException
```
    Throws:
    
    MolgenisModelException
  - getCreateFKeySql
```
protected String getCreateFKeySql(AttributeMetaData att)
```
  - getUniqueSql
```
protected String getUniqueSql(AttributeMetaData att)
```
  - getEntityMetaData
```
public EntityMetaData getEntityMetaData()
```
    Specified by:
    
    getEntityMetaData in interface Repository
  - iterator
```
public Iterator<Entity> iterator()
```
    Specified by:
    
    iterator in interface Iterable<Entity>
  - getInsertSql
```
protected String getInsertSql()
```
  - findOne
```
public Entity findOne(Query q)
```
    Specified by:
    
    findOne in interface Repository
    
    Overrides:
    
    findOne in class AbstractRepository
  - findOne
```
public Entity findOne(Object id)
```
    Specified by:
    
    findOne in interface Repository
    
    Overrides:
    
    findOne in class AbstractRepository
  - findAll
```
public Iterable<Entity> findAll(Iterable<Object> ids)
```
    Specified by:
    
    findAll in interface Repository
    
    Overrides:
    
    findAll in class AbstractRepository
  - getSelectSql
```
protected String getSelectSql(Query q,
                              List<Object> parameters)
```
  - findAll
```
public Iterable<Entity> findAll(Query q)
```
    Specified by:
    
    findAll in interface Repository
    
    Overrides:
    
    findAll in class AbstractRepository
  - getWhereSql
```
protected String getWhereSql(Query q,
                             List<Object> parameters,
                             int mrefFilterIndex)
```
  - getSortSql
```
protected String getSortSql(Query q)
```
  - getUpdateSql
```
protected String getUpdateSql()
```
  - delete
```
public void delete(Entity entity)
```
    Specified by:
    
    delete in interface Repository
    
    Overrides:
    
    delete in class AbstractRepository
  - delete
```
public void delete(Iterable<? extends Entity> entities)
```
    Specified by:
    
    delete in interface Repository
    
    Overrides:
    
    delete in class AbstractRepository
  - getDeleteSql
```
public String getDeleteSql()
```
  - deleteById
```
public void deleteById(Object id)
```
    Specified by:
    
    deleteById in interface Repository
    
    Overrides:
    
    deleteById in class AbstractRepository
  - deleteById
```
public void deleteById(Iterable<Object> ids)
```
    Specified by:
    
    deleteById in interface Repository
    
    Overrides:
    
    deleteById in class AbstractRepository
  - deleteAll
```
public void deleteAll()
```
    Specified by:
    
    deleteAll in interface Repository
    
    Overrides:
    
    deleteAll in class AbstractRepository
  - add
```
public Integer add(Iterable<? extends Entity> entities)
```
    Specified by:
    
    add in interface Repository
    
    Overrides:
    
    add in class AbstractRepository
  - add
```
public void add(Entity entity)
```
    Specified by:
    
    add in interface Repository
    
    Overrides:
    
    add in class AbstractRepository
  - update
```
public void update(Entity entity)
```
    Specified by:
    
    update in interface Repository
    
    Overrides:
    
    update in class AbstractRepository
  - update
```
public void update(Iterable<? extends Entity> entities)
```
    Specified by:
    
    update in interface Repository
    
    Overrides:
    
    update in class AbstractRepository
  - tableExists
```
public boolean tableExists()
```
  - addAttributeToTable
```
public void addAttributeToTable(String attributeName)
```
    Adds an attribute to the table for this entity. Looks up the type of the attribute in metaData.
    
    Parameters:
    
    attributeName - name of the attribute to add
  - createTableIfNotExists
```
public boolean createTableIfNotExists()
```
    Creates the table for this repository if it does not already exist.
    
    Returns:
    
    boolean indicating if the table was created
  - getCapabilities
```
public Set<RepositoryCapability> getCapabilities()
```
    Specified by:
    
    getCapabilities in interface Repository
  - count
```
public long count(Query q)
```
    Specified by:
    
    count in interface Repository
    
    Overrides:
    
    count in class AbstractRepository
  - getFromSql
```
protected String getFromSql(Query q)
```
  - getCountSql
```
protected String getCountSql(Query q,
                             List<Object> parameters)
```

Class MysqlRepository

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.molgenis.data.support.AbstractRepository

Methods inherited from class java.lang.Object

Methods inherited from interface org.molgenis.data.Repository

Methods inherited from interface java.lang.Iterable

Methods inherited from interface java.io.Closeable

Field Detail

BATCH_SIZE

Constructor Detail

MysqlRepository

Method Detail

setMetaData

drop

dropAttribute

getDropSql

create

addAttribute

addAttributeSync

getMrefCreateSql

getCreateSql

getAlterSql

getCreateFKeySql

getUniqueSql

getEntityMetaData

iterator

getInsertSql

findOne

findOne

findAll

getSelectSql

findAll

getWhereSql

getSortSql

getUpdateSql

delete

delete

getDeleteSql

deleteById

deleteById

deleteAll

add

add

update

update

tableExists

addAttributeToTable

createTableIfNotExists

getCapabilities

count

getFromSql

getCountSql