.getTargetList().size());

        ConnectorInstance connectorInstance = context.getSourceConnectorInstance();

        // 获取关系型数据库连接，实现自己的业务逻辑...
        if (connectorInstance instanceof DatabaseConnectorInstance) {
            DatabaseConnectorInstance db = (DatabaseConnectorInstance) connectorInstance;
            // 方式一（推荐）：
            String query = "select * from my_user";
            db.execute(databaseTemplate -> databaseTemplate.queryForList(