MySQL源数据是binary类型推到pgsql中数据类型为varchar帮我写个JavaScript代码，这个在表输入和表输出之间字段名称为status，alarm_status这俩，其他的不用转换

### 数据迁移策略 为了将 MySQL 中 `binary` 类型的数据迁移到 PostgreSQL 的 `varchar` 字段，可以采用分步处理的方式。这涉及读取原始数据、转换数据类型以及写入目标数据库。 #### 1. 连接配置 首先设置连接到两个不同数据库所需的参数： ```javascript const { Client } = require('pg'); const mysql = require('mysql'); // 创建 MySQL 和 PostgreSQL 客户端实例 const mysqlConnection = mysql.createConnection({ host: 'localhost', user: 'root', password: '', database: 'source_db' }); const pgClient = new Client({ host: 'localhost', port: 5432, user: 'postgres', password: 'password', database: 'target_db' }); ``` #### 2. 查询并提取二进制数据 从 MySQL 表中查询包含 `status` 和 `alarm_status` 列的结果集，并将其作为字符串表示形式获取出来[^1]。 ```javascript async function fetchBinaryData() { await mysqlConnection.connect(); const queryResult = await mysqlConnection.promise().query( "SELECT id, status AS binStatus, alarm_status AS binAlarmStatus FROM your_table" ); return queryResult[0]; } ``` #### 3. 转换函数定义 创建用于把二进制值转成十六进制字符串的方法，以便于存储为字符格式： ```javascript function binaryToHex(binaryValue) { let hexString = ''; for (let i = 0; i < binaryValue.length; ++i) { hexString += ('0' + (binaryValue[i] & 0xFF).toString(16)).slice(-2); } return hexString; } ``` #### 4. 插入更新操作 准备 SQL 语句模板来向 PostgreSQL 添加新记录或修改现有条目；这里假设已经存在相应的表结构[^2]。 ```javascript async function migrateRecords(records) { try { await pgClient.connect(); records.forEach(record => { const sqlInsertOrUpdate = ` INSERT INTO target_table(id,status,alarm_status) VALUES($1,$2,$3) ON CONFLICT (id) DO UPDATE SET status=EXCLUDED.status, alarm_status=EXCLUDED.alarm_status`; pgClient.query(sqlInsertOrUpdate, [ record.id, binaryToHex(Buffer.from(record.binStatus)), binaryToHex(Buffer.from(record.binAlarmStatus)) ]); }); } catch (err) { console.error(err.stack); } finally { await pgClient.end(); } } ``` 通过上述方法组合调用即可完成整个过程：先执行 `fetchBinaryData()` 获取源数据，再利用返回的对象数组传递给 `migrateRecords()` 函数进行实际的迁移工作。