1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- 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")
|