Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
sboikov committed Jan 23, 2015
1 parent 9520f00 commit 531d9ba
Show file tree
Hide file tree
Showing 18 changed files with 71 additions and 71 deletions.
Expand Up @@ -92,7 +92,7 @@ public class GridJdbcComplexQuerySelfTest extends GridCommonAbstractTest {
personCache.put(new GridCacheAffinityKey<>("p2", "o1"), new Person(2, "Joe Black", 35, 1));
personCache.put(new GridCacheAffinityKey<>("p3", "o2"), new Person(3, "Mike Green", 40, 2));

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -89,7 +89,7 @@ private CacheConfiguration cacheConfiguration(@Nullable String name) throws Exce
@Override protected void beforeTestsStarted() throws Exception {
startGridsMultiThreaded(2);

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -73,7 +73,7 @@ public class GridJdbcEmptyCacheSelfTest extends GridCommonAbstractTest {
@Override protected void beforeTestsStarted() throws Exception {
startGrid();

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -30,7 +30,7 @@

import static org.apache.ignite.cache.GridCacheMode.*;
import static org.apache.ignite.cache.GridCacheWriteSynchronizationMode.*;
import static org.apache.ignite.jdbc.GridJdbcDriver.*;
import static org.apache.ignite.jdbc.IgniteJdbcDriver.*;

/**
* Test JDBC with several local caches.
Expand Down Expand Up @@ -92,7 +92,7 @@ public class GridJdbcLocalCachesSelfTest extends GridCommonAbstractTest {
assert cache2.putx("key1", 3);
assert cache2.putx("key2", 4);

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -87,7 +87,7 @@ public class GridJdbcMetadataSelfTest extends GridCommonAbstractTest {
personCache.put(new GridCacheAffinityKey<>("p2", "o1"), new Person("Joe Black", 35, 1));
personCache.put(new GridCacheAffinityKey<>("p3", "o2"), new Person("Mike Green", 40, 2));

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -102,7 +102,7 @@ public class GridJdbcPreparedStatementSelfTest extends GridCommonAbstractTest {
cache.put(1, o);
cache.put(2, new TestObject(2));

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -94,7 +94,7 @@ public class GridJdbcResultSetSelfTest extends GridCommonAbstractTest {
cache.put(1, o);
cache.put(2, new TestObject(2));

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -86,7 +86,7 @@ public class GridJdbcStatementSelfTest extends GridCommonAbstractTest {
cache.put("p2", new Person(2, "Joe", "Black", 35));
cache.put("p3", new Person(3, "Mike", "Green", 40));

Class.forName("org.gridgain.jdbc.GridJdbcDriver");
Class.forName("org.apache.ignite.jdbc.IgniteJdbcDriver");
}

/** {@inheritDoc} */
Expand Down
Expand Up @@ -25,12 +25,12 @@

import static java.sql.ResultSet.*;
import static java.util.concurrent.TimeUnit.*;
import static org.apache.ignite.jdbc.GridJdbcDriver.*;
import static org.apache.ignite.jdbc.IgniteJdbcDriver.*;

/**
* JDBC connection implementation.
*/
class GridJdbcConnection implements Connection {
class IgniteJdbcConnection implements Connection {
/** Validation task name. */
private static final String VALID_TASK_NAME =
"org.apache.ignite.internal.processors.cache.query.jdbc.GridCacheQueryJdbcValidationTask";
Expand Down Expand Up @@ -60,7 +60,7 @@ class GridJdbcConnection implements Connection {
* @param props Additional properties.
* @throws SQLException In case GridGain client failed to start.
*/
GridJdbcConnection(String url, Properties props) throws SQLException {
IgniteJdbcConnection(String url, Properties props) throws SQLException {
assert url != null;
assert props != null;

Expand Down Expand Up @@ -167,7 +167,7 @@ class GridJdbcConnection implements Connection {
@Override public DatabaseMetaData getMetaData() throws SQLException {
ensureNotClosed();

return new GridJdbcDatabaseMetadata(this);
return new IgniteJdbcDatabaseMetadata(this);
}

/** {@inheritDoc} */
Expand Down Expand Up @@ -315,7 +315,7 @@ class GridJdbcConnection implements Connection {
if (resSetHoldability != HOLD_CURSORS_OVER_COMMIT)
throw new SQLFeatureNotSupportedException("Invalid holdability (transactions are not supported).");

GridJdbcStatement stmt = new GridJdbcStatement(this);
IgniteJdbcStatement stmt = new IgniteJdbcStatement(this);

if (timeout > 0)
stmt.timeout(timeout);
Expand All @@ -337,7 +337,7 @@ class GridJdbcConnection implements Connection {
if (resSetHoldability != HOLD_CURSORS_OVER_COMMIT)
throw new SQLFeatureNotSupportedException("Invalid holdability (transactions are not supported).");

GridJdbcPreparedStatement stmt = new GridJdbcPreparedStatement(this, sql);
IgniteJdbcPreparedStatement stmt = new IgniteJdbcPreparedStatement(this, sql);

if (timeout > 0)
stmt.timeout(timeout);
Expand Down Expand Up @@ -541,7 +541,7 @@ private void ensureNotClosed() throws SQLException {
* @return Internal statement.
* @throws SQLException In case of error.
*/
GridJdbcStatement createStatement0() throws SQLException {
return (GridJdbcStatement)createStatement();
IgniteJdbcStatement createStatement0() throws SQLException {
return (IgniteJdbcStatement)createStatement();
}
}
Expand Up @@ -20,7 +20,7 @@
/**
* Connection properties.
*/
class GridJdbcConnectionInfo {
class IgniteJdbcConnectionInfo {
/** URL. */
private final String url;

Expand All @@ -36,7 +36,7 @@ class GridJdbcConnectionInfo {
/**
* @param url URL.
*/
GridJdbcConnectionInfo(String url) {
IgniteJdbcConnectionInfo(String url) {
this.url = url;
}

Expand Down

0 comments on commit 531d9ba

Please sign in to comment.