Add assertions to unit tests

Author: linghengqian

README.md

@@ -46,6 +46,6 @@ More background at https://lists.apache.org/thread/63lr45kyh78s64spwsjxjy8zdyzpr
 
 The current project has not yet carried out any release work.
 
-## contribute
+## Contributing
 
 Refer to [CONTRIBUTING](./doc/CONTRIBUTING.md) .

doc/CONTRIBUTING.md

@@ -43,14 +43,15 @@ gnome-text-editor ~/.m2/setting.xml
 ```
 
 ```xml
+
 <settings>
-  <servers>
-    <server>
-      <id>central</id>
-      <username><!-- your token username --></username>
-      <password><!-- your token password --></password>
-    </server>
-  </servers>
+    <servers>
+        <server>
+            <id>central</id>
+            <username><!-- Aloha, your token username --></username>
+            <password><!-- Aloha, your token password --></password>
+        </server>
+    </servers>
 </settings>
 ```
 
@@ -65,5 +66,5 @@ mvn clean install -DskipTests
 cd ../
 git clone [email protected]:linghengqian/hive-server2-jdbc-driver.git
 cd ./hive-server2-jdbc-driver/
-./mvnw -Ppublishing-via-the-central-portal -DskipTests clean deploy
+./mvnw -Ppublishing-via-the-central-portal -Dgpg.keyname=${Aloha, your keyname} -DskipTests clean deploy
 ```

hive-server2-jdbc-driver-thin/src/test/java/com/github/linghengqian/hive/server2/jdbc/driver/thin/HiveServer2Test.java hive-server2-jdbc-driver-thin/src/test/java/com/github/linghengqian/hive/server2/jdbc/driver/thin/HiveServer2ThinTest.java

@@ -9,16 +9,19 @@
 import org.testcontainers.utility.DockerImageName;
 
 import java.sql.Connection;
+import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
 
 import static org.awaitility.Awaitility.await;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.is;
 
 @SuppressWarnings({"SqlNoDataSourceInspection", "resource"})
 @Testcontainers
-public class HiveServer2Test {
+public class HiveServer2ThinTest {
 
     @Container
     public static final GenericContainer<?> CONTAINER = new GenericContainer<>(DockerImageName.parse("apache/hive:4.1.0-SNAPSHOT"))
@@ -41,11 +44,17 @@ void test() throws SQLException {
              Connection connection = hikariDataSource.getConnection();
              Statement statement = connection.createStatement()) {
             statement.execute("CREATE DATABASE demo_ds_0");
-            statement.executeQuery("show tables");
+            ResultSet firstResultSet = statement.executeQuery("show tables");
+            assertThat(firstResultSet.next(), is(false));
             statement.execute("create table hive_example(a string, b int) partitioned by(c int)");
+            statement.execute("alter table hive_example add partition(c=1)");
             statement.execute("insert into hive_example partition(c=1) values('a', 1), ('a', 2),('b',3)");
-            statement.executeQuery("select count(distinct a) from hive_example");
-            statement.executeQuery("select sum(b) from hive_example");
+            ResultSet secondResultSet = statement.executeQuery("select count(distinct a) from hive_example");
+            assertThat(secondResultSet.next(), is(true));
+            assertThat(secondResultSet.getInt("_c0"), is(2));
+            ResultSet thirdResultSet = statement.executeQuery("select sum(b) from hive_example");
+            assertThat(thirdResultSet.next(), is(true));
+            assertThat(thirdResultSet.getInt("_c0"), is(6));
         }
     }
 }

hive-server2-jdbc-driver-uber/src/test/java/com/github/linghengqian/hive/server2/jdbc/driver/uber/HiveServer2Test.java hive-server2-jdbc-driver-uber/src/test/java/com/github/linghengqian/hive/server2/jdbc/driver/uber/HiveServer2UberTest.java

@@ -9,16 +9,19 @@
 import org.testcontainers.utility.DockerImageName;
 
 import java.sql.Connection;
+import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
 
 import static org.awaitility.Awaitility.await;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.is;
 
 @SuppressWarnings({"SqlNoDataSourceInspection", "resource"})
 @Testcontainers
-public class HiveServer2Test {
+public class HiveServer2UberTest {
 
     @Container
     public static final GenericContainer<?> CONTAINER = new GenericContainer<>(DockerImageName.parse("apache/hive:4.1.0-SNAPSHOT"))
@@ -41,11 +44,17 @@ void test() throws SQLException {
              Connection connection = hikariDataSource.getConnection();
              Statement statement = connection.createStatement()) {
             statement.execute("CREATE DATABASE demo_ds_0");
-            statement.executeQuery("show tables");
+            ResultSet firstResultSet = statement.executeQuery("show tables");
+            assertThat(firstResultSet.next(), is(false));
             statement.execute("create table hive_example(a string, b int) partitioned by(c int)");
+            statement.execute("alter table hive_example add partition(c=1)");
             statement.execute("insert into hive_example partition(c=1) values('a', 1), ('a', 2),('b',3)");
-            statement.executeQuery("select count(distinct a) from hive_example");
-            statement.executeQuery("select sum(b) from hive_example");
+            ResultSet secondResultSet = statement.executeQuery("select count(distinct a) from hive_example");
+            assertThat(secondResultSet.next(), is(true));
+            assertThat(secondResultSet.getInt("_c0"), is(2));
+            ResultSet thirdResultSet = statement.executeQuery("select sum(b) from hive_example");
+            assertThat(thirdResultSet.next(), is(true));
+            assertThat(thirdResultSet.getInt("_c0"), is(6));
         }
     }
 }

pom.xml

@@ -138,6 +138,12 @@
                                 <goals>
                                     <goal>sign</goal>
                                 </goals>
+                                <configuration>
+                                    <!--suppress MavenModelInspection -->
+                                    <keyname>${gpg.keyname}</keyname>
+                                    <!--suppress MavenModelInspection -->
+                                    <passphraseServerId>${gpg.keyname}</passphraseServerId>
+                                </configuration>
                             </execution>
                         </executions>
                     </plugin>