-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathBadges.js
67 lines (57 loc) · 1.63 KB
/
Badges.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
const fs = require('fs');
const { Pool } = require('pg');
const parseString = require('xml2js').parseString;
// PostgreSQL database configuration
const pool = new Pool({
user: 'postgres',
host: 'localhost',
database: 'Arduino',
password: 'love123',
port: 5432,
});
// Read the XML file
fs.readFile('./data/Badges.xml', 'utf-8', (err, data) => {
if (err) {
console.error('Error reading XML file:', err);
return;
}
// Parse the XML data
parseString(data, async (parseErr, result) => {
if (parseErr) {
console.error('Error parsing XML:', parseErr);
return;
}
console.log(result.badges.row);
try {
// Extract the rows from the XML
const rows = Array.isArray(result.badges.row)
? result.badges.row
: [result.badges.row];
console.log(rows);
// Insert data into PostgreSQL
const client = await pool.connect();
for (const row of rows) {
console.log(rows);
const { Id, UserId, Name, Date, Class, TagBased } = row.$;
// Customize this query based on your table structure
const query = {
text: 'INSERT INTO badges(id, user_id, name, date, class, tag_based) VALUES($1, $2, $3, $4, $5, $6)',
values: [
Id,
UserId,
Name,
Date,
Class,
TagBased === 'True' ? true : false,
],
};
await client.query(query);
}
console.log('Data inserted successfully.');
} catch (error) {
console.error('Error inserting data:', error);
} finally {
pool.end(); // Close the PostgreSQL pool
}
});
});