亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Neo4j 第十二篇:使用Python驅動訪問Neo4j

系統 1522 0

neo4j官方驅動支持Python語言,驅動程序主要包含Driver類型和Session類型。Driver對象包含Neo4j數據庫的詳細信息,包括主機url、安全驗證等配置,還管理著連接池(Connection Pool);Session對象是執行事務單元的邏輯上下文,事務是在Session的上下文中執行的。由于Session不是線程安全的,并能夠從Driver對象管理的連接池中回收利用(Recycle)連接,因此,Session對象是輕量級的(lightweight),用完之后應立即銷毀(disposable)。

Driver對象和Session對象的關系是:Driver對象負責管理連接池,從連接池中分配連接創建Session對象;Session對象在單個線程中接收Cypher和啟動事務,在事務執行完成之后,立即銷毀Session對象;Driver對象負責回收連接,等待為下一個Session對象分配連接。

一,安裝Python版本的Neo4j驅動

如果不關注驅動的版本,可以安裝最新版本的Python驅動

            pip install neo4j-driver
          

也可以在pip命令中指定python驅動的版本:

            pip install neo4j-driver==
            
              $PYTHON_DRIVER_VERSION
pip install neo4j
            
            -driver==
            
              1.4
            
            .
            
              0
            
          

二,Driver對象

在安裝neo4j驅動之后,在python代碼中導入GraphDatabase模塊,用于查詢和更新圖數據庫:

            
              from
            
             neo4j.v1 
            
              import
            
             GraphDatabase
          

1,創建Driver對象實例

輸入neo4j數據庫的uri,用戶的安全驗證,實例化Driver對象,并創建連接池:

            
              from
            
             neo4j.v1 
            
              import
            
            
               GraphDatabase
uri 
            
            = 
            
              "
            
            
              bolt://localhost:7687
            
            
              "
            
            
              
_driver 
            
            = GraphDatabase.driver(uri, auth=(
            
              "
            
            
              neo4j
            
            
              "
            
            , 
            
              "
            
            
              password
            
            
              "
            
            ))
          

使用close()函數關閉Driver對象分配的任何連接:

            _driver.close()
          

2,使用Driver對象來創建Session對象

Driver對象從連接池中分配連接,創建Session對象:

            _session = _driver.session()
          

三,Session對象

Session的創建是一個輕量級的操作,由于Session不是線程安全的,因此,Session通常應該在單個線程中短暫存續,用完之后立即銷毀。在Python中,推薦在with上下文中創建和銷毀Session對象:

            
              def
            
            
               add_person(name):
    with _driver.session() as session:
        session.run(
            
            
              "
            
            
              CREATE (a:Person {name: $name})
            
            
              "
            
            , name=name)
          

Session對象是執行事務的邏輯上下文,Cypher支持兩種方式來提交事務。

1,以自動提交方式提交事務

以自動提交事務的方式執行Cypher查詢,在Session對象執行Cypher語句之后,事務立即提交,因此,一次事務只能執行一個Cyper查詢,返回的結果是StatementResult對象:

            _session.run(statement, parameters=None)
          

2,以事務函數方式來提交事務

事務函數包含事務的工作單元,以事務函數方式提交事務是neo4j推薦的提交事務的方式,在事務函數方式中,一個事務可以執行多個Cypher查詢。

首先,定義事務函數,傳遞相應的參數(Cypher語句和參數):

            
              def
            
            
               create_person_node(tx, name):
    tx.run(
            
            
              "
            
            
              CREATE (a:Person {name: $name}) RETURN id(a)
            
            
              "
            
            , name=name)
          

然后,在Session對象中啟動寫事務(write_transaction)來調用事務函數,返回的結果是StatementResult對象:

            
              def
            
            
               add_person(driver, name):
    with _driver.session() as session:
        
            
            
              #
            
            
               Caller for transactional unit of work
            
            
              return
            
             session.write_transaction(create_person_node, name)
          

三,StatementResult和Record

Session對象執行Cypher查詢的結果是StatementResult類型,該類型實際上是由Record對象構成的集合,該類型的常用函數如下:

  • keys():是由Record集合的Key構成的元組
  • records():是由Record對象構成的集合
  • single():從result變 量中獲取下一個記錄,返回值是下一個Record或None
  • peek():從結果中獲取下一個Record對象,而該對象仍然保留在結果緩存中,以便后續進行處理。

Record類型是一個有序的Key/Value對的序列,這意味著,Record對象類似于由Key:Value構成的列表,Key字段的值可以通過字段名稱或索引來訪問:

  • items() :是由元組(key,value)構成的列表
  • keys():是由一個Record對象的key構成的元組
  • values():是由一個Record對象的value構成的元組
  • index(key):返回指定Key在Record對象內的索引

?

附,示例代碼

              
                class
              
              
                 BookmarksExample(object):

    
              
              
                def
              
              
                __init__
              
              
                (self, uri, user, password):
        self._driver 
              
              = GraphDatabase.driver(uri, auth=
              
                (user, password))

    
              
              
                def
              
              
                 close(self):
        self._driver.close()

    
              
              
                #
              
              
                 Create a person node.
              
              
                    @classmethod
    
              
              
                def
              
              
                 create_person(cls, tx, name):
        tx.run(
              
              
                "
              
              
                CREATE (:Person {name: $name})
              
              
                "
              
              , name=
              
                name)

    
              
              
                #
              
              
                 Create an employment relationship to a pre-existing company node.
              
              
                #
              
              
                 This relies on the person first having been created.
              
              
                    @classmethod
    
              
              
                def
              
              
                 employ(cls, tx, person_name, company_name):
        tx.run(
              
              
                "
              
              
                MATCH (person:Person {name: $person_name}) 
              
              
                "
              
              
                "
              
              
                MATCH (company:Company {name: $company_name}) 
              
              
                "
              
              
                "
              
              
                CREATE (person)-[:WORKS_FOR]->(company)
              
              
                "
              
              
                ,
               person_name
              
              =person_name, company_name=
              
                company_name)

    
              
              
                #
              
              
                 Create a friendship between two people.
              
              
                    @classmethod
    
              
              
                def
              
              
                 create_friendship(cls, tx, name_a, name_b):
        tx.run(
              
              
                "
              
              
                MATCH (a:Person {name: $name_a}) 
              
              
                "
              
              
                "
              
              
                MATCH (b:Person {name: $name_b}) 
              
              
                "
              
              
                "
              
              
                MERGE (a)-[:KNOWS]->(b)
              
              
                "
              
              
                ,
               name_a
              
              =name_a, name_b=
              
                name_b)

    
              
              
                #
              
              
                 Match and display all friendships.
              
              
                    @classmethod
    
              
              
                def
              
              
                 print_friendships(cls, tx):
        result 
              
              = tx.run(
              
                "
              
              
                MATCH (a)-[:KNOWS]->(b) RETURN a.name, b.name
              
              
                "
              
              
                )
        
              
              
                for
              
               record 
              
                in
              
              
                 result:
            
              
              
                print
              
              (
              
                "
              
              
                {} knows {}
              
              
                "
              
              .format(record[
              
                "
              
              
                a.name
              
              
                "
              
              ] ,record[
              
                "
              
              
                b.name
              
              
                "
              
              
                ]))

    
              
              
                def
              
              
                 main(self):
        saved_bookmarks 
              
              = []  
              
                #
              
              
                 To collect the session bookmarks
              
              
                #
              
              
                 Create the first person and employment relationship.
              
              
                        with self._driver.session() as session_a:
            session_a.write_transaction(self.create_person, 
              
              
                "
              
              
                Alice
              
              
                "
              
              
                )
            session_a.write_transaction(self.employ, 
              
              
                "
              
              
                Alice
              
              
                "
              
              , 
              
                "
              
              
                Wayne Enterprises
              
              
                "
              
              
                )
            saved_bookmarks.append(session_a.last_bookmark())

        
              
              
                #
              
              
                 Create the second person and employment relationship.
              
              
                        with self._driver.session() as session_b:
            session_b.write_transaction(self.create_person, 
              
              
                "
              
              
                Bob
              
              
                "
              
              
                )
            session_b.write_transaction(self.employ, 
              
              
                "
              
              
                Bob
              
              
                "
              
              , 
              
                "
              
              
                LexCorp
              
              
                "
              
              
                )
            saved_bookmarks.append(session_b.last_bookmark())

        
              
              
                #
              
              
                 Create a friendship between the two people created above.
              
              
        with self._driver.session(bookmarks=
              
                saved_bookmarks) as session_c:
            session_c.write_transaction(self.create_friendship, 
              
              
                "
              
              
                Alice
              
              
                "
              
              , 
              
                "
              
              
                Bob
              
              
                "
              
              
                )
            session_c.read_transaction(self.print_friendships)




              
              
                class
              
              
                 Neo4jProvider:

    
              
              
                def
              
              
                __init__
              
              
                (self, uri, user, password):
        self._driver 
              
              = GraphDatabase.driver(uri, auth=
              
                (user, password))

    
              
              
                def
              
              
                 close(self):
        self._driver.close()

    
              
              
                def
              
              
                 add_greeting_node(self, message):
        with self._driver.session() as session:
            session.write_transaction(self._create_greeting, message)

    @staticmethod
    
              
              
                def
              
              
                 _create_greeting(tx, message):
        tx.run(
              
              
                "
              
              
                CREATE (a:Greeting) SET a.message = $message 
              
              
                "
              
              , message=message)
            
View Code

?

?

參考文檔:

Neo4j Bolt Driver for Python

Sessions and transactions


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 毛片免费观看日本中文 | 有码中文字幕在线观看 | 成人影院一区二区三区 | 亚洲视屏一区 | 欧美国产一区二区二区 | 草久在线观看视频 | 精品一区二区三区视频在线观看 | 日韩精品久久久毛片一区二区 | 我要操影院 | 午夜在线视频网站 | 日本一级毛片免费播 | 亚洲韩国日本一级二级r级 亚洲韩精品欧美一区二区三区 | 免费观看一级特黄欧美大片 | 377p亚洲欧洲日本大胆色噜噜 | 超97在线观看精品国产 | 四虎影视在线麻豆国产 | 亚洲欧美久久精品 | 国产视频一区二区在线播放 | 国产一久久香蕉国产线看观看 | 国产二区三区毛片 | 四虎永久影院永久影库 | 毛片毛片免费看 | 国产一级视频在线观看 | 91久久精品一区二区三区 | 国产在线麻豆精品 | 欧美日韩一级片在线观看 | 91在线看视频 | 精品一区二区三 | 99热这里只有精品2 99热这里只有精品3 | 91精品国产免费久久久久久 | 国产日产欧美一区二区三区 | 成人免费久久精品国产片久久影院 | xxxx性xx另类 | 色伊伊| 97影院理论在线观看 | 日日摸日日碰夜夜97 | 国产综合亚洲精品一区 | 麻豆国产原创最新在线视频 | 亚洲在线久久 | 国产91在线视频 | 欧美一级片在线免费观看 |