[feature][plugin][sybase] datax support sybase plugins. #1780 add unit testcase

This commit is contained in:
mengxiaopeng 2023-07-05 15:25:42 +08:00
parent d6dbe17abd
commit 4095a2a954
2 changed files with 61 additions and 0 deletions

View File

@ -65,6 +65,12 @@
<systemPath>${project.basedir}/libs/jconn4-16.0.jar</systemPath>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13.2</version>
<scope>test</scope>
</dependency>
</dependencies>

View File

@ -0,0 +1,55 @@
package com.alibaba.datax.plugin.reader.sybasereader;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.assertEquals;
public class SybaseDatabaseUnitTest {
private Connection connection;
@Before
public void setUp() {
// 连接到 Sybase 数据库
String jdbcUrl = "jdbc:sybase:Tds:192.172.172.80:1680/database";
String username = "admin";
String password = "admin123";
try {
connection = DriverManager.getConnection(jdbcUrl, username, password);
} catch (SQLException e) {
e.printStackTrace();
}
}
@After
public void tearDown() {
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
@Test
public void testDatabaseQuery() throws SQLException {
String query = "SELECT COUNT(*) FROM your_table";
int expectedRowCount = 10; // 假设期望返回的行数是 10
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(query);
resultSet.next();
int rowCount = resultSet.getInt(1);
assertEquals(expectedRowCount, rowCount);
}
}