HTML项目中如何用JS将本地文件导入Neo4j？技术咨询

Great question! Since you're already using JavaScript to export your data to a local file, integrating Neo4j import functionality can be done smoothly with the official Neo4j JavaScript Driver. Let's break this down step by step:

Prerequisites #

• Make sure you have Node.js installed (browser-based JS has restrictions accessing local files and connecting directly to Neo4j securely, so Node.js is the way to go here).
• Install the Neo4j JavaScript Driver via npm:

  npm install neo4j-driver
  

• Ensure your Neo4j database is running, and you have the correct connection credentials (username, password, database URI).

Step 1: Read Your Local Exported File #

First, you'll need to pull the data from the file you exported earlier. Let's assume it's a JSON file (common for JS exports):

const fs = require('fs').promises;
const neo4j = require('neo4j-driver');

async function readLocalFile(filePath) {
  try {
    const fileContent = await fs.readFile(filePath, 'utf8');
    return JSON.parse(fileContent); // Convert JSON string to JS objects
  } catch (error) {
    console.error('Failed to read file:', error);
    throw error;
  }
}

Step 2: Connect to Neo4j and Import Data #

Next, establish a connection to your Neo4j instance and use Cypher queries to insert the data. We'll use MERGE instead of CREATE to avoid duplicate nodes if you run the script multiple times:

async function importToNeo4j(data, uri, username, password, database = 'neo4j') {
  // Initialize the driver with your credentials
  const driver = neo4j.driver(uri, neo4j.auth.basic(username, password));

  try {
    // Verify the connection works
    await driver.verifyConnectivity();
    console.log('Connected to Neo4j successfully');

    // Create a session to interact with the database
    const session = driver.session({ database });

    try {
      // Loop through each entry in your data (adjust based on your structure)
      for (const item of data) {
        // Customize this Cypher query to match your node/relationship schema
        const query = `
          MERGE (n:YourNodeLabel {id: $id})
          SET n.name = $name, n.email = $email
        `;

        // Run the query with your data as parameters
        await session.run(query, {
          id: item.id,
          name: item.name,
          email: item.email
        });
      }

      console.log('Data imported successfully!');
    } finally {
      // Always close the session when done
      await session.close();
    }
  } catch (error) {
    console.error('Error during import:', error);
    throw error;
  } finally {
    // Close the driver connection
    await driver.close();
  }
}

Step 3: Tie It All Together #

Create a main function to run the full workflow:

async function main() {
  const filePath = './your-exported-data.json'; // Replace with your file path
  const neo4jUri = 'bolt://localhost:7687'; // Default Neo4j URI
  const neo4jUsername = 'neo4j'; // Your Neo4j username
  const neo4jPassword = 'your-secure-password'; // Your Neo4j password

  try {
    const data = await readLocalFile(filePath);
    await importToNeo4j(data, neo4jUri, neo4jUsername, neo4jPassword);
  } catch (error) {
    console.error('Import workflow failed:', error);
  }
}

// Execute the main function
main();

Key Tips #

• Schema Customization: Adjust the Cypher query and parameter mapping to match your actual data structure (node labels, properties, relationships).
• Bulk Imports: For large datasets, use batch transactions instead of processing one item at a time to boost performance and ensure consistency:

  // Example batch processing with 100 items per batch
  const batchSize = 100;
  for (let i = 0; i < data.length; i += batchSize) {
    const batch = data.slice(i, i + batchSize);
    await session.writeTransaction(tx => {
      return Promise.all(batch.map(item => tx.run(query, item)));
    });
  }
  

• CSV Files: If your exported file is CSV, you can parse it in JS with the csv-parser package, or use Neo4j's LOAD CSV Cypher command directly (note: the file needs to be accessible to the Neo4j server for this method).
• Security: Never hardcode credentials in production! Use environment variables (e.g., process.env.NEO4J_PASSWORD) instead.

内容的提问来源于stack exchange，提问作者BigA