Connect Oracle and AWS Redshift in our serverless environment

class OracleSourceSelect {
    async init() {
        // TODO: Create your oracle credential
        // More info at https://yepcode.io/docs/integrations/oracle/#credential-configuration
        const oraclePool = await yepcode.integration.oracle(
            "your-oracle-credential-name"
        );
        this.connection = await oraclePool.getConnection();
    }

    async fetch(publish, done) {
        const stream = this.connection
            // TODO: Customize your sql query
            .queryStream(`SELECT * FROM your_table_name`);
        stream.on("data", async (row) => {
            // TODO: map your row to an item
            const item = {
                ...row
            };

            await publish(item);
        });
        stream.on("error", (error) => {
            throw error;
        });
        stream.on("end", () => stream.destroy());
        stream.on("close", done);
    }

    async close() {
        await this.connection.close();
    }
}

class AwsRedshiftTargetInsert {
    async init() {
        // TODO: Create your aws-redshift credential
        // More info at https://yepcode.io/docs/integrations/aws-redshift/#credential-configuration
        this.awsRedshift = yepcode.integration.awsRedshift(
            "your-aws-redshift-credential-name"
        );
    }

    async consume(item) {
        // TODO: Customize your sql query
        const sqlStatement = `INSERT INTO your-table-name VALUES (${item.someProp}, '${item.someStringProp}')`;

        // TODO: Customize the command to be executed
        // More info at https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-redshift-data/interfaces/executestatementcommandinput.html
        this.awsRedshift.send(
            new ExecuteStatementCommand({
                ClusterIdentifier: "your-cluster-identifier",
                Database: "your-database",
                DbUser: "your-db-user",
                Sql: sqlStatement,
            })
        );
    }

    async close() {}
}