Flutter图数据库驱动插件neo4driver的使用

发布于 1周前 作者 sinazl 来自 Flutter

Flutter 图数据库驱动插件 neo4driver 的使用

简介

进入图片描述

Neo4Driver 是一个用于 Neo4j 的 Dart 驱动库。该库使用的是 Neo4J HTTP API 数据库。

安装

在项目的 pubspec.yaml 文件中添加 Neo4Driver 并运行 pub get：

dependencies:
  neo4driver: any

使用

初始化

// 初始化 Neo4Client，传入数据库的相关信息
NeoClient.withAuthorization(
  username: '{database_username}', // 数据库用户名
  password: '{database_password}', // 数据库密码
  databaseAddress: 'http://{database_address}:7474/', // 数据库地址
  databaseName: '{database_name}', // 数据库名称
);

初始化后的使用

// 创建一个关系
await NeoClient().createRelationship(
  startNodeId: 1, // 起始节点ID
  endNodeId: 2, // 结束节点ID
  relationshipLabel: "rel_label", // 关系标签
  properties: {
    "Property1": "value1", // 属性1
    "Property2": 2, // 属性2
  },
);

特性

  • findRelationshipById
  • findAllRelationship
  • findRelationshipWithStartNodeIdEndNodeId
  • findRelationshipWithNodeProperties
  • isRelationshipExistsBetweenTwoNodes
  • updateNodeById
  • updateRelationshipById
  • findAllNodesByProperties
  • findAllNodes
  • findNodeById
  • findAllNodesByLabel
  • getNodesWithHighestProperty
  • computeShortestPathDijkstra
  • computeDistanceBetweenTwoPoints
  • createGraphProjection
  • createRelationship
  • createRelationshipFromNodeToNodes
  • createNodeWithNode
  • createNode
  • deleteNodeById
  • deleteAllNode

示例代码

以下是一个完整的示例代码，展示了如何使用 neo4driver 插件连接到 Neo4j 数据库并进行基本操作：

import 'package:flutter/material.dart';
import 'package:neo4driver/neo4driver.dart';

void main() async {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('Neo4Driver 示例'),
        ),
        body: Center(
          child: ElevatedButton(
            onPressed: () async {
              // 初始化 Neo4Client
              var client = await NeoClient.withAuthorization(
                username: 'your_username', // 替换为你的用户名
                password: 'your_password', // 替换为你的密码
                databaseAddress: 'http://localhost:7474/', // 替换为你的数据库地址
                databaseName: 'neo4j', // 替换为你的数据库名
              );

              // 创建一个关系
              await client.createRelationship(
                startNodeId: 1,
                endNodeId: 2,
                relationshipLabel: "rel_label",
                properties: {
                  "Property1": "value1",
                  "Property2": 2,
                },
              );

              // 显示提示信息
              ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text('关系创建成功')));
            },
            child: Text('创建关系'),
          ),
        ),
      ),
    );
  }
}

更多关于Flutter图数据库驱动插件neo4driver的使用的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html

Harmonyos Next教程
1 回复

更多关于Flutter图数据库驱动插件neo4driver的使用的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html


当然，以下是一个关于如何在Flutter项目中使用neo4driver插件来与Neo4j图数据库进行交互的示例代码。neo4driver是一个Dart包，用于与Neo4j数据库进行通信。

前提条件

  1. 确保你已经安装了Flutter SDK。
  2. 确保你有一个正在运行的Neo4j数据库实例。
  3. 在你的pubspec.yaml文件中添加neo4driver依赖。
dependencies:
  flutter:
    sdk: flutter
  neo4driver: ^latest_version  # 替换为最新的版本号

步骤

  1. 安装依赖
flutter pub get
  1. 创建一个Flutter项目（如果还没有的话）
flutter create my_neo4j_app
cd my_neo4j_app
  1. 编写代码

以下是一个简单的示例，展示如何使用neo4driver连接到Neo4j数据库并执行一个基本的查询。

import 'package:flutter/material.dart';
import 'package:neo4driver/neo4driver.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Neo4j Example',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: MyHomePage(),
    );
  }
}

class MyHomePage extends StatefulWidget {
  @override
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  String _result = 'Loading...';

  @override
  void initState() {
    super.initState();
    _connectToNeo4j();
  }

  Future<void> _connectToNeo4j() async {
    // 配置Neo4j连接信息
    final driver = GraphDatabaseDriver.bolt(
      'bolt://localhost:7687', // Neo4j数据库地址
      AuthTokens.basic('neo4j', 'password'), // 用户名和密码
    );

    try {
      // 打开一个会话
      final session = driver.session();

      // 执行一个查询
      final result = await session.run('MATCH (n) RETURN n LIMIT 5');

      // 处理查询结果
      List<String> nodes = result.records.map((record) {
        final node = record.get(0).asNode();
        return node['name'].toString(); // 假设节点有一个名为'name'的属性
      }).toList();

      // 更新UI
      setState(() {
        _result = nodes.join(', ');
      });

      // 关闭会话
      await session.close();
    } catch (e) {
      // 处理错误
      setState(() {
        _result = 'Error: ${e.toString()}';
      });
    } finally {
      // 关闭驱动
      await driver.close();
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Flutter Neo4j Example'),
      ),
      body: Center(
        child: Text(
          _result,
          style: TextStyle(fontSize: 24),
        ),
      ),
    );
  }
}

说明

  1. 配置连接信息：使用GraphDatabaseDriver.bolt方法配置Neo4j的连接信息，包括地址和认证信息。
  2. 打开会话：使用driver.session()方法打开一个会话。
  3. 执行查询：使用session.run方法执行Cypher查询。
  4. 处理结果：遍历查询结果并提取所需信息。
  5. 更新UI：使用setState方法更新UI以显示查询结果。
  6. 关闭会话和驱动：确保在完成后关闭会话和驱动以释放资源。

这个示例代码展示了基本的连接、查询和结果处理流程。根据你的实际需求，你可以进一步扩展和修改这个示例。

回到顶部