SQLDatabase (PretronicDatabaseQuery 1.1.0.24 API)

java.lang.Object
- net.pretronic.databasequery.common.AbstractDatabase<SQLDatabaseDriver>
- - net.pretronic.databasequery.sql.SQLDatabase

All Implemented Interfaces:: Database

public class SQLDatabase
extends AbstractDatabase<SQLDatabaseDriver>

Field Summary

Fields
Modifier and Type Field Description

private DataSource dataSource

Fields
Modifier and Type	Field	Description
`private DataSource`	`dataSource`

Constructor Summary

Constructors
Constructor Description

SQLDatabase(String name, SQLDatabaseDriver driver, DataSource dataSource)

Constructors
Constructor	Description
`SQLDatabase(String name, SQLDatabaseDriver driver, DataSource dataSource)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CreateQuery`	`createCollection(String name)`	Create a new collection on a remote server or on a local file database.
`void`	`drop()`	Delete this database and all contained collections on a remote server or a local file database.
`void`	`dropCollection(String name)`	Drop a collection on a remote server or a local file database.
`QueryResult`	`execute(Query... queries)`	Execute a query over this database.
`<R> R`	`executeResultQuery(String query, boolean commit, PreparedStatementConsumer preparedStatementConsumer, ResultSetFunction<R> resultSetFunction)`
`<R> R`	`executeResultQuery(String query, boolean commit, PreparedStatementConsumer preparedStatementConsumer, ResultSetFunction<R> resultSetFunction, Consumer<SQLException> exceptionConsumer)`
`void`	`executeUpdateQuery(String sql, boolean commit)`
`void`	`executeUpdateQuery(String query, boolean commit, PreparedStatementConsumer preparedStatementConsumer)`
`Number[]`	`executeUpdateQuery(String query, boolean commit, PreparedStatementConsumer preparedStatementConsumer, String[] keyColumns)`
`Number[]`	`executeUpdateQuery(String query, boolean commit, PreparedStatementConsumer preparedStatementConsumer, String[] keyColumns, Consumer<SQLException> exceptionConsumer)`
`DatabaseCollection`	`getCollection(String name)`	Get a collection form this database.
`DataSource`	`getDataSource()`
`QueryGroup`	`group()`	Create a query group for executing multiple queries at the same time.
`void`	`handleDatabaseQueryExecuteFailedException(SQLException exception, String query)`
`boolean`	`isLocalConnected()`
`private PreparedStatement`	`setPrepareStatement(Connection connection, String query, String[] keyColumns)`
`QueryTransaction`	`transact()`	Create a new transaction for executing different queries over the same connection.

Methods inherited from class net.pretronic.databasequery.common.AbstractDatabase
getDriver, getLogger, getName

Methods inherited from interface net.pretronic.databasequery.api.Database
createCollection, createCollection, dropCollection

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

Field Detail
- dataSource
```
private final DataSource dataSource
```

Constructor Detail

SQLDatabase

public SQLDatabase(String name,
                   SQLDatabaseDriver driver,
                   DataSource dataSource)

Method Detail

getCollection
```
public DatabaseCollection getCollection(String name)
```
Description copied from interface: Database

Get a collection form this database.
Important = A new collection object is also returned, when the collection doesn't exist on the remote server.

Parameters:

name - The name of the collection on the remote server

Returns:

A new collection object for accessing the data

createCollection
```
public CreateQuery createCollection(String name)
```
Description copied from interface: Database

Create a new collection on a remote server or on a local file database.

Parameters:

name - The name of the collection

Returns:

A new collection object for accessing the data

dropCollection
```
public void dropCollection(String name)
```
Description copied from interface: Database

Drop a collection on a remote server or a local file database.

Parameters:

name - The name of the collection

drop
```
public void drop()
```
Description copied from interface: Database

Delete this database and all contained collections on a remote server or a local file database.

transact
```
public QueryTransaction transact()
```
Description copied from interface: Database

Create a new transaction for executing different queries over the same connection.
With a transaction you are able to undo your queries in case if an error.

For more information see QueryTransaction

Returns:

The new transaction object

group
```
public QueryGroup group()
```
Description copied from interface: Database

Create a query group for executing multiple queries at the same time.

Returns:

The new query group

execute
```
public QueryResult execute(Query... queries)
```
Description copied from interface: Database

Execute a query over this database.

Parameters:

queries - All queries for executing

Returns:

The result of the execution

isLocalConnected
```
public boolean isLocalConnected()
```

getDataSource
```
public DataSource getDataSource()
```

executeResultQuery

public <R> R executeResultQuery(String query,
                                boolean commit,
                                PreparedStatementConsumer preparedStatementConsumer,
                                ResultSetFunction<R> resultSetFunction,
                                Consumer<SQLException> exceptionConsumer)

executeResultQuery

public <R> R executeResultQuery(String query,
                                boolean commit,
                                PreparedStatementConsumer preparedStatementConsumer,
                                ResultSetFunction<R> resultSetFunction)

executeUpdateQuery

public Number[] executeUpdateQuery(String query,
                                   boolean commit,
                                   PreparedStatementConsumer preparedStatementConsumer,
                                   String[] keyColumns,
                                   Consumer<SQLException> exceptionConsumer)

setPrepareStatement

private PreparedStatement setPrepareStatement(Connection connection,
                                              String query,
                                              String[] keyColumns)
                                       throws SQLException

Throws:: SQLException

executeUpdateQuery

public Number[] executeUpdateQuery(String query,
                                   boolean commit,
                                   PreparedStatementConsumer preparedStatementConsumer,
                                   String[] keyColumns)

executeUpdateQuery

public void executeUpdateQuery(String query,
                               boolean commit,
                               PreparedStatementConsumer preparedStatementConsumer)

executeUpdateQuery

public void executeUpdateQuery(String sql,
                               boolean commit)

handleDatabaseQueryExecuteFailedException

public void handleDatabaseQueryExecuteFailedException(SQLException exception,
                                                      String query)

Class SQLDatabase

Field Summary

Constructor Summary

Method Summary

Methods inherited from class net.pretronic.databasequery.common.AbstractDatabase

Methods inherited from interface net.pretronic.databasequery.api.Database

Methods inherited from class java.lang.Object

Field Detail

dataSource

Constructor Detail

SQLDatabase

Method Detail

getCollection

createCollection

dropCollection

drop

transact

group

execute

isLocalConnected

getDataSource

executeResultQuery

executeResultQuery

executeUpdateQuery

setPrepareStatement

executeUpdateQuery

executeUpdateQuery

executeUpdateQuery

handleDatabaseQueryExecuteFailedException