public class DbImpl extends org.rapidoid.activity.NamedActivity<org.rapidoid.db.Database> implements org.rapidoid.db.Database, Serializable
Constructor and Description |
---|
DbImpl(String name,
org.rapidoid.inmem.InMem inmem,
org.rapidoid.db.DbSchema schema) |
DbImpl(String name,
String filename) |
Modifier and Type | Method and Description |
---|---|
org.rapidoid.db.Database |
as(String username) |
void |
clear() |
<E> org.rapidoid.db.DbColumn<E> |
column(Map<String,Object> map,
String name,
Class<E> type) |
void |
delete(long id) |
void |
delete(Object record) |
void |
destroy() |
<E> void |
each(org.rapidoid.lambda.Operation<E> lambda) |
<E> List<E> |
find(Class<E> clazz,
org.rapidoid.lambda.Predicate<E> match,
Comparator<E> orderBy) |
<E> List<E> |
find(Class<E> clazz,
String query,
Object... args) |
<E> List<E> |
find(Iterable<Long> ids) |
<E> List<E> |
find(org.rapidoid.lambda.Predicate<E> match) |
<E> List<E> |
find(String searchPhrase) |
<E> E |
get(long id) |
<E> E |
get(long id,
Class<E> clazz) |
<E> List<E> |
getAll(Class<E> clazz) |
<E> List<E> |
getAll(Collection<Long> ids) |
<E> List<E> |
getAll(long... ids) |
long |
getIdOf(Object record) |
<E> E |
getIfExists(long id) |
long |
getVersionOf(long id) |
org.rapidoid.db.Database |
halt() |
void |
initAndLoad() |
long |
insert(Object record) |
boolean |
isActive() |
<E> org.rapidoid.db.DbList<E> |
list(Object holder,
String relation) |
void |
load(InputStream in) |
long |
persist(Object record) |
long |
persistedIdOf(Object record) |
<T> T |
readColumn(long id,
String column) |
<E> org.rapidoid.db.DbRef<E> |
ref(Object holder,
String relation) |
<E> void |
refresh(E record) |
void |
saveTo(OutputStream output) |
org.rapidoid.db.DbSchema |
schema() |
<E> org.rapidoid.db.DbSet<E> |
set(Object holder,
String relation) |
org.rapidoid.db.Database |
shutdown() |
long |
size() |
org.rapidoid.db.Database |
start() |
org.rapidoid.db.Database |
sudo() |
String |
toString() |
void |
transaction(Runnable transaction,
boolean readOnly) |
void |
transaction(Runnable transaction,
boolean readOnly,
org.rapidoid.lambda.Callback<Void> callback) |
void |
update(long id,
Object record) |
void |
update(Object record) |
public DbImpl(String name, org.rapidoid.inmem.InMem inmem, org.rapidoid.db.DbSchema schema)
public void initAndLoad()
initAndLoad
in interface org.rapidoid.db.Database
public long insert(Object record)
insert
in interface org.rapidoid.db.Database
public void delete(long id)
delete
in interface org.rapidoid.db.Database
public void delete(Object record)
delete
in interface org.rapidoid.db.Database
public <E> E get(long id)
get
in interface org.rapidoid.db.Database
public <E> E getIfExists(long id)
getIfExists
in interface org.rapidoid.db.Database
public <E> E get(long id, Class<E> clazz)
get
in interface org.rapidoid.db.Database
public <E> void refresh(E record)
refresh
in interface org.rapidoid.db.Database
public void update(long id, Object record)
update
in interface org.rapidoid.db.Database
public void update(Object record)
update
in interface org.rapidoid.db.Database
public long persist(Object record)
persist
in interface org.rapidoid.db.Database
public long persistedIdOf(Object record)
persistedIdOf
in interface org.rapidoid.db.Database
public <T> T readColumn(long id, String column)
readColumn
in interface org.rapidoid.db.Database
public <E> List<E> getAll(Class<E> clazz)
getAll
in interface org.rapidoid.db.Database
public <E> List<E> getAll(long... ids)
getAll
in interface org.rapidoid.db.Database
public <E> List<E> getAll(Collection<Long> ids)
getAll
in interface org.rapidoid.db.Database
public <E> List<E> find(org.rapidoid.lambda.Predicate<E> match)
find
in interface org.rapidoid.db.Database
public <E> List<E> find(Iterable<Long> ids)
find
in interface org.rapidoid.db.Database
public <E> List<E> find(Class<E> clazz, org.rapidoid.lambda.Predicate<E> match, Comparator<E> orderBy)
find
in interface org.rapidoid.db.Database
public <E> List<E> find(String searchPhrase)
find
in interface org.rapidoid.db.Database
public <E> List<E> find(Class<E> clazz, String query, Object... args)
find
in interface org.rapidoid.db.Database
public <E> void each(org.rapidoid.lambda.Operation<E> lambda)
each
in interface org.rapidoid.db.Database
public void transaction(Runnable transaction, boolean readOnly)
transaction
in interface org.rapidoid.db.Database
public void transaction(Runnable transaction, boolean readOnly, org.rapidoid.lambda.Callback<Void> callback)
transaction
in interface org.rapidoid.db.Database
public void saveTo(OutputStream output)
saveTo
in interface org.rapidoid.db.Database
public void load(InputStream in)
load
in interface org.rapidoid.db.Database
public org.rapidoid.db.Database start()
start
in interface org.rapidoid.activity.Activity<org.rapidoid.db.Database>
public org.rapidoid.db.Database halt()
halt
in interface org.rapidoid.activity.Activity<org.rapidoid.db.Database>
public org.rapidoid.db.Database shutdown()
shutdown
in interface org.rapidoid.activity.Activity<org.rapidoid.db.Database>
public boolean isActive()
isActive
in interface org.rapidoid.activity.Activity<org.rapidoid.db.Database>
public void destroy()
destroy
in interface org.rapidoid.db.Database
public long size()
size
in interface org.rapidoid.db.Database
public void clear()
clear
in interface org.rapidoid.db.Database
public long getIdOf(Object record)
getIdOf
in interface org.rapidoid.db.Database
public long getVersionOf(long id)
getVersionOf
in interface org.rapidoid.db.Database
public <E> org.rapidoid.db.DbColumn<E> column(Map<String,Object> map, String name, Class<E> type)
column
in interface org.rapidoid.db.Database
public <E> org.rapidoid.db.DbList<E> list(Object holder, String relation)
list
in interface org.rapidoid.db.Database
public <E> org.rapidoid.db.DbSet<E> set(Object holder, String relation)
set
in interface org.rapidoid.db.Database
public <E> org.rapidoid.db.DbRef<E> ref(Object holder, String relation)
ref
in interface org.rapidoid.db.Database
public org.rapidoid.db.DbSchema schema()
schema
in interface org.rapidoid.db.Database
public org.rapidoid.db.Database as(String username)
as
in interface org.rapidoid.db.Database
public org.rapidoid.db.Database sudo()
sudo
in interface org.rapidoid.db.Database
Copyright © 2014–2015 Nikolche Mihajlovski. All rights reserved.