ibm_db

import * as ibmdb from 'ibm_db'; // Configuration for a local DB2 database // Replace with your actual connection string const connStr = process.env.DB2_CONN_STR ?? 'DATABASE=sample;HOSTNAME=localhost;PORT=50000;PROTOCOL=TCPIP;UID=db2inst1;PWD=password;'; async function runQuery() { let conn; try { console.log('Attempting to connect to DB2...'); conn = await ibmdb.open(connStr); console.log('Connection successful!'); // Create a table if it doesn't exist try { await conn.query("CREATE TABLE my_table (id INT, name VARCHAR(50))"); console.log('Table my_table created successfully (or already exists).'); } catch (createErr) { if (createErr.message.includes('SQLCODE=-601')) { // -601 is object already exists console.log('Table my_table already exists, skipping creation.'); } else { throw createErr; // Re-throw other errors } } // Insert data const insertResult = await conn.query("INSERT INTO my_table (id, name) VALUES (1, 'Alice')"); console.log('Inserted 1 row:', insertResult.rowCount); // Select data const data = await conn.query("SELECT * FROM my_table WHERE id = 1"); console.log('Selected data:', data); // Update data const updateResult = await conn.query("UPDATE my_table SET name = 'Bob' WHERE id = 1"); console.log('Updated 1 row:', updateResult.rowCount); } catch (err) { console.error('Error during database operation:', err.message); } finally { if (conn) { try { await conn.close(); console.log('Connection closed.'); } catch (closeErr) { console.error('Error closing connection:', closeErr.message); } } } } runQuery();