Package org.neo4j.graphdb

Examples of org.neo4j.graphdb.Transaction.finish()

120
121
122
123
124
125
126
127
128
129
130
          }
        }
        if (cnt++%10000==0){
          System.out.println(cnt);
          tx.success();
          tx.finish();
          tx = graphDB.beginTx();
        }
      }
      tx.success();
    }catch (Exception e){
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
      }
      tx.success();
    }catch (Exception e){
      e.printStackTrace();
    }finally{
      tx.finish();
    }
  }
 
  public void getNodesWithHighPageRank(){
    Index<Node> ix = graphDB.index().forNodes("pageRank");
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
    try {
      for (Entry<Long, Double> e : nodeIndex.entrySet()) {
        cnt++;
        if (cnt > 50000){
          tx.success();
          tx.finish();
          cnt=0;
          tx = db.beginTx();
          IOHelper.log("updated another 50k nodes with PR properties");
        }
        Node n = db.getNodeById(e.getKey());
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        Node n = db.getNodeById(e.getKey());
        n.setProperty("pageRankValue", e.getValue());
      }
      tx.success();
    } finally {
      tx.finish();
    }
  }

  private HashMap<Long, Double> getNodesToIndex() {
    HashMap<Long, Double> nodeIndex = new HashMap<Long, Double>();
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
   
    // DynamicRelationshipType testType = DynamicRelationshipType.withName("test");
    // node1.createRelationshipTo(node2, testType);
   
    tx.success();
    tx.finish();
   
  }

 
  public static void main(String[] args) {
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
          if (topkCnt>=k)break;         
        } 
        if (++transactionCount % transactionThreshhold == 0){
          tx.success();
          tx.finish();
          tx = graphDB.beginTx();
          IOHelper.log(transactionCount + " nodes have been attached with coAuthorshiprelations so far");     
        }
//        IOHelper.log(log);
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
//        System.out.println(" ");
      }
      tx.success();
    }finally{
      tx.finish();
    }
  }
 
 
  public void calculateCoAuthors(int transactionThreshhold){
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
          Relationship coAuthorRel = author.createRelationshipTo(coAuthor, DBRelationshipTypes.CO_AUTHOR_COUNT);
          coAuthorRel.setProperty(DBRelationshipProperties.CO_AUTHOR_COUNT,coAuthors.get(coAuthor));
         
          if (++transactionCount % transactionThreshhold == 0){
            tx.success();
            tx.finish();
            tx = graphDB.beginTx();
            IOHelper.log(transactionCount + " coAuthor relations have been inserted so far");
            System.out.println("current relation's count is " + coAuthors.get(coAuthor)); 
          }         
        }     
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
          }         
        }     
      }
      tx.success();
    }finally{
      tx.finish();
    }
  }
 
 
  public void calculateLikesToCiteAuthors(int transactionThreshhold){
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
          Relationship coAuthorRel = author.createRelationshipTo(citedAuthor, DBRelationshipTypes.CITES_AUTHOR);
          coAuthorRel.setProperty(DBRelationshipProperties.CITATION_COUNT,citedAuthors.get(citedAuthor));
         
          if (++transactionCount % transactionThreshhold == 0){
            tx.success();
            tx.finish();
            tx = graphDB.beginTx();
            IOHelper.log(transactionCount + " citedAuthor relations have been inserted so far");
            System.out.println("current relation's count is " + citedAuthors.get(citedAuthor));     
          }         
        }     
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.