1. db.
js
// [Link]
const mysql = require('mysql');
const connection = [Link]({
host: 'localhost',
user: 'root',
password: '', // replace with your password
database: 'testdb' // make sure this DB exists
});
[Link](err => {
if (err) throw err;
[Link]('Connected to MySQL');
});
[Link] = connection;
2. [Link]
// [Link]
const db = require('./db');
const query = `
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100),
email VARCHAR(100)
)
`;
[Link](query, (err, result) => {
if (err) throw err;
[Link]('Table created or already exists');
});
3. [Link]
// [Link]
const db = require('./db');
const name = Ahmad;
const email = 'ahmad@[Link]';
[Link](
'INSERT INTO users (name, email) VALUES (?, ?)',
[name, email],
(err, result) => {
if (err) throw err;
[Link]('Inserted user with ID:', [Link]);
}
);
4. [Link]
// [Link]
const db = require('./db');
[Link]('SELECT * FROM users', (err, results) => {
if (err) throw err;
[Link]('Users:', results);
});
5. [Link]
// [Link]
const db = require('./db');
const id = 1;
const newName = Ahmad Updated';
const newEmail = '[Link]@[Link]';
[Link](
'UPDATE users SET name = ?, email = ? WHERE id = ?',
[newName, newEmail, id],
(err, result) => {
if (err) throw err;
[Link](`Updated ${[Link]} row(s)`);
}
);
6. [Link]
// [Link]
const db = require('./db');
const id = 1;
[Link]('DELETE FROM users WHERE id = ?', [id], (err, result) => {
if (err) throw err;
[Link](`Deleted ${[Link]} row(s)`);
});
2. [Link] — Connection with Promisified Query
// [Link]
const mysql = require('mysql');
const util = require('util');
const connection = [Link]({
host: 'localhost',
user: 'root',
password: '', // your MySQL password
database: 'testdb'
});
[Link](err => {
if (err) throw err;
[Link]('Connected to MySQL');
});
// Promisify the query method
[Link] = [Link]([Link]);
[Link] = connection;
3. [Link]
// [Link]
const db = require('./db');
(async () => {
try {
await [Link](`
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100),
email VARCHAR(100)
)
`);
[Link]('Table created.');
} catch (err) {
[Link](' Error:', err);
} finally {
[Link]();
}
})();
4. [Link]
// [Link]
const db = require('./db');
(async () => {
try {
const result = await [Link]('INSERT INTO users (name, email) VALUES
(?, ?)', [
abc, abc@[Link]'
]);
[Link](' Inserted ID:', [Link]);
} catch (err) {
[Link](' Error:', err);
} finally {
[Link]();
}
})();
5. [Link]
// [Link]
const db = require('./db');
(async () => {
try {
const users = await [Link]('SELECT * FROM users');
[Link]('Users:', users);
} catch (err) {
[Link](' Error:', err);
} finally {
[Link]();
}
})();
6. [Link]
// [Link]
const db = require('./db');
(async () => {
try {
const result = await [Link]('UPDATE users SET name = ?, email = ?
WHERE id = ?', [
'Updated abcd, xyz@[Link]', 1
]);
[Link](`Updated ${[Link]} row(s)`);
} catch (err) {
[Link]('Error:', err);
} finally {
[Link]();
}
})();
7. [Link]
// [Link]
const db = require('./db');
(async () => {
try {
const result = await [Link]('DELETE FROM users WHERE id = ?', [1]);
[Link](`Deleted ${[Link]} row(s)`);
} catch (err) {
[Link](' Error:', err);
} finally {
[Link]();
}
})();