1.安装neo4j驱动程序:
您可以使用pip安装Neo4j驱动程序。
pip install neo4j
from neo4j import GraphDatabase
driver = GraphDatabase.driver("bolt://localhost:7687", auth=("username", "password"))
session = driver.session()
3.读取CSV文件并将数据插入到Neo4j中:
假设您的订单CSV文件包含以下列:
OrderID
CustomerID
OrderDate
您的订单明细CSV文件包含以下列:
OrderDetailID
OrderID
ProductID
Quantity
您可以使用以下代码将数据插入到Neo4j中:
import csv
# Import orders
with open('orders.csv', 'r') as csvfile:
csvreader = csv.reader(csvfile)
for row in csvreader:
query = "CREATE (:Order { OrderID: $OrderID, CustomerID: $CustomerID, OrderDate: $OrderDate })"
params = {"OrderID": row[0], "CustomerID": row[1], "OrderDate": row[2]}
session.run(query, params)
# Import order details
with open('order_details.csv', 'r') as csvfile:
csvreader = csv.reader(csvfile)
for row in csvreader:
query = "MATCH (o:Order { OrderID: $OrderID }) CREATE (o)-[:HAS_ORDER_DETAIL]->(:OrderDetail { OrderDetailID: $OrderDetailID, ProductID: $ProductID, Quantity: $Quantity })"
params = {"OrderID": row[1], "OrderDetailID": row[0], "ProductID": row[2], "Quantity": row[3]}
session.run(query, params)
以上代码中,我们使用了csv模块来读取CSV文件中的数据。然后,我们使用CREATE语句将订单和订单明细存储到Neo4j中。在订单明细的情况下,我们使用MATCH语句找到与该订单相关联的订单节点,并使用CREATE语句创建订单明细节点,并在两个节点之间创建一个关系。
这是一个基本的代码框架,您可能需要根据您的数据和模型进行修改。
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net