Browse Source

注释测试步骤

pull/1/head
yichen 3 years ago
parent
commit
94d8a5d71c
  1. 1
      agent/src/test/java/Test.java
  2. 15
      service/src/test/java/ServiceTest.java
  3. 6
      service/src/test/java/Test.java
  4. 8
      service/src/test/java/TestUtils.java

1
agent/src/test/java/Test.java

@ -31,6 +31,7 @@ public class Test {
Socket socket = AgentStarter.myDispatcherImpl.CACHE.getSocket(DBProperties.HSQL); Socket socket = AgentStarter.myDispatcherImpl.CACHE.getSocket(DBProperties.HSQL);
socket.connect(); socket.connect();
socket.open();
} }

15
service/src/test/java/ServiceTest.java

@ -1,12 +1,11 @@
import com.corundumstudio.socketio.SocketIOClient; import com.corundumstudio.socketio.SocketIOClient;
import com.corundumstudio.socketio.SocketIOServer;
import com.fanruan.cache.ClientCache; import com.fanruan.cache.ClientCache;
import com.fanruan.utils.DBProperties; import com.fanruan.utils.DBProperties;
import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import java.net.Socket;
import java.sql.*; import java.sql.*;
import java.util.Properties; import java.util.Properties;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
@ -34,8 +33,6 @@ public class ServiceTest extends AutoStarter{
); );
ft.run(); ft.run();
ft.get(); ft.get();
} }
@Test @Test
@ -51,8 +48,14 @@ public class ServiceTest extends AutoStarter{
PreparedStatement pst = null; PreparedStatement pst = null;
ResultSet rs = null; ResultSet rs = null;
try { try {
// 创建 连接
conn = DriverManager.getConnection("jdbc:hsqldb:mem:test", info); conn = DriverManager.getConnection("jdbc:hsqldb:mem:test", info);
// 创建 statement
st = conn.createStatement(); st = conn.createStatement();
// 创建表
st.executeUpdate("DROP TABLE student IF EXISTS;"); st.executeUpdate("DROP TABLE student IF EXISTS;");
st.executeUpdate("CREATE TABLE student (" + st.executeUpdate("CREATE TABLE student (" +
@ -63,6 +66,7 @@ public class ServiceTest extends AutoStarter{
"PRIMARY KEY (student_id)" + "PRIMARY KEY (student_id)" +
");"); ");");
// 插入数据
st.executeUpdate("INSERT INTO student VALUES" + st.executeUpdate("INSERT INTO student VALUES" +
"(1, '张三', '上海')," + "(1, '张三', '上海')," +
"(2, '李四', '北京')," + "(2, '李四', '北京')," +
@ -70,7 +74,7 @@ public class ServiceTest extends AutoStarter{
// 预查询语句 删除指定 ID
pst = conn.prepareStatement("delete from student where student_id = ?"); pst = conn.prepareStatement("delete from student where student_id = ?");
pst.setInt(1, 1); pst.setInt(1, 1);
@ -82,6 +86,7 @@ public class ServiceTest extends AutoStarter{
String[] nameStrings = new String[]{"张三", "李四", "王五"}; String[] nameStrings = new String[]{"张三", "李四", "王五"};
String[] addressStrings = new String[]{"上海", "北京", "成都"}; String[] addressStrings = new String[]{"上海", "北京", "成都"};
// 结果集断言
int num = 2; int num = 2;
while(rs.next()) { while(rs.next()) {
Assertions.assertEquals(rs.getInt("student_id"), num); Assertions.assertEquals(rs.getInt("student_id"), num);

6
service/src/test/java/Test.java

@ -16,9 +16,9 @@ public class Test {
String[] DBs = new String[]{ String[] DBs = new String[]{
DBProperties.MYSQL, DBProperties.MYSQL,
DBProperties.POSTGRESQL, DBProperties.POSTGRESQL,
// DBProperties.SQLSERVER, DBProperties.SQLSERVER,
// DBProperties.DB2, DBProperties.DB2,
// DBProperties.ORACLE DBProperties.ORACLE
}; };
new ServerStater(DBs); new ServerStater(DBs);

8
service/src/test/java/TestUtils.java

@ -1,8 +0,0 @@
/**
* @author Yichen Dai
* @date 2022/8/16 11:36
*/
public class TestUtils {
}
Loading…
Cancel
Save