iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor rxjava-jdbc

Browse Source
This commit is contained in:
Ahmed Tawila 2017-09-30 22:37:00 +02:00
parent 9f9fa935a8
commit ecb0e9924a
7 changed files with 28 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rxjava/src/test/java/com/baeldung/rxjava/jdbc/AutomapClassTest.java
View File

@ -15,11 +15,11 @@ import rx.Observable;
public class AutomapClassTest {
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
Observable<Integer> create = null;
Observable<Integer> insert1, insert2 = null;
private Observable<Integer> create = null;
private Observable<Integer> insert1, insert2 = null;
@Before
public void setup() {

8
rxjava/src/test/java/com/baeldung/rxjava/jdbc/AutomapInterfaceTest.java
View File

@ -15,11 +15,11 @@ import rx.Observable;
public class AutomapInterfaceTest {
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
Observable<Integer> create = null;
Observable<Integer> insert1, insert2 = null;
private Observable<Integer> create = null;
private Observable<Integer> insert1, insert2 = null;
@Before
public void setup() {

6
rxjava/src/test/java/com/baeldung/rxjava/jdbc/BasicQueryTypesTest.java
View File

@ -15,10 +15,10 @@ import rx.Observable;
public class BasicQueryTypesTest {
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
Observable<Integer> create, insert1, insert2, insert3, update, delete = null;
private Observable<Integer> create, insert1, insert2, insert3, update, delete = null;
@Test
public void whenCreateTableAndInsertRecords_thenCorrect() {

10
rxjava/src/test/java/com/baeldung/rxjava/jdbc/InsertBlobTest.java
View File

@ -18,13 +18,13 @@ import rx.Observable;
public class InsertBlobTest {
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
String expectedDocument = null;
String actualDocument = null;
private String expectedDocument = null;
private String actualDocument = null;
Observable<Integer> create, insert = null;
private Observable<Integer> create, insert = null;
@Before
public void setup() throws IOException {

10
rxjava/src/test/java/com/baeldung/rxjava/jdbc/InsertClobTest.java
View File

@ -17,13 +17,13 @@ import rx.Observable;
public class InsertClobTest {
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
String expectedDocument = null;
String actualDocument = null;
private String expectedDocument = null;
private String actualDocument = null;
Observable<Integer> create, insert = null;
private Observable<Integer> create, insert = null;
@Before
public void setup() throws IOException {

8
rxjava/src/test/java/com/baeldung/rxjava/jdbc/ReturnKeysTest.java
View File

@ -13,11 +13,11 @@ import rx.Observable;
public class ReturnKeysTest {
Observable<Boolean> begin, commit = null;
Observable<Integer> createStatement, insertStatement, updateStatement = null;
private Observable<Boolean> begin = null;
private Observable<Integer> createStatement = null;
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
@Before
public void setup() {

7
rxjava/src/test/java/com/baeldung/rxjava/jdbc/TransactionTest.java
View File

@ -12,11 +12,10 @@ import rx.Observable;
public class TransactionTest {
Observable<Boolean> begin, commit = null;
Observable<Integer> createStatement, insertStatement, updateStatement = null;
private Observable<Integer> createStatement = null;
ConnectionProvider connectionProvider = Connector.connectionProvider;
Database db = Database.from(connectionProvider);
private ConnectionProvider connectionProvider = Connector.connectionProvider;
private Database db = Database.from(connectionProvider);
@Test
public void whenCommitTransaction_thenRecordUpdated() {