node.js中的mysql和套接字交互

const mysql = require('mysql');
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'database_name'
});

connection.connect((err) => {
  if (err) throw err;
  console.log('Connected to MySQL database');
});

const sql = 'SELECT * FROM users';
connection.query(sql, (err, results) => {
  if (err) throw err;
  console.log(results);
});

const user = { name: 'John', email: 'john@example.com' };
const sql = 'INSERT INTO users SET ?';
connection.query(sql, user, (err, result) => {
  if (err) throw err;
  console.log('Data inserted:', result);
});

const sql = 'UPDATE users SET email = ? WHERE id = ?';
const values = ['newemail@example.com', 1];
connection.query(sql, values, (err, result) => {
  if (err) throw err;
  console.log('Data updated:', result);
});

const sql = 'DELETE FROM users WHERE id = ?';
const id = 1;
connection.query(sql, id, (err, result) => {
  if (err) throw err;
  console.log('Data deleted:', result);
});

const net = require('net');

// 创建服务器
const server = net.createServer((socket) => {
  console.log('Client connected');

  // 接收客户端发送的数据
  socket.on('data', (data) => {
    console.log('Received data:', data.toString());

    // 向客户端发送数据
    socket.write('Hello from server');
  });

  // 客户端断开连接
  socket.on('end', () => {
    console.log('Client disconnected');
  });
});

// 监听端口
server.listen(3000, () => {
  console.log('Server started on port 3000');
});