diff --git a/sybasereader/pom.xml b/sybasereader/pom.xml
index 1c826fb4..cc3a3840 100644
--- a/sybasereader/pom.xml
+++ b/sybasereader/pom.xml
@@ -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>
 
diff --git a/sybasereader/src/test/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseDatabaseUnitTest.java b/sybasereader/src/test/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseDatabaseUnitTest.java
new file mode 100644
index 00000000..f77caccd
--- /dev/null
+++ b/sybasereader/src/test/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseDatabaseUnitTest.java
@@ -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);
+    }
+}