const fs = require('fs');
const turf = require('@turf/turf');
const wkx = require('wkx');
const Database = require('./db');
const moment = require('moment');

const pool = new Database({
    host: '192.168.100.30',
    database: 'real3d',
    user: 'postgres',
    password: 'postgis',
    port: 5432,
});

async function readFile(input, output) {
    // 连接到数据库，设置模式
    await pool.connect();
    await pool.setSchema('vector');

    const data = fs.readFileSync(input, 'utf8');
    const geojson = JSON.parse(data);

    let insertSqlStatements = '';

    for (let i = 0; i < geojson.features.length; i++) {


        let feature = geojson.features[i];

        let ewktString = wkx.Geometry.parseGeoJSON(feature.geometry).toWkt();

        const insertSql = `INSERT INTO vector."TB_CZKFBJ_ONE" (id,geom) VALUES (${i},public.st_geomfromewkt('${ewktString}'));`;

        insertSqlStatements+=insertSql+`\n`

        // console.log(insertSql);
        // const res = await pool.query(insertSql);
        // console.log(i);
    }
    fs.writeFileSync(output, insertSqlStatements, 'utf8');
    console.log("1");
}

readFile("./data/geojson/修正id.geojson", "./data/geojson/修正.sql")