Package org.structr.core.app

Examples of org.structr.core.app.App.tx()

826
827
828
829
830
831
832
833
834
835
836
  @Export
  public void diff(final String file) throws FrameworkException {

    final App app = StructrApp.getInstance(securityContext);

    try (final Tx tx = app.tx()) {

      final String source = IOUtils.toString(new FileInputStream(file));
      final List<InvertibleModificationOperation> changeSet = new LinkedList<>();
      final Page diffPage = Importer.parsePageFromSource(securityContext, source, this.getProperty(Page.name) + "diff");
View Full Code Here
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
      public void flush() throws IOException {

        final String source = toString();

        final App app = StructrApp.getInstance();
        try (Tx tx = app.tx()) {

          // parse page from modified source
          Page modifiedPage = Importer.parsePageFromSource(securityContext, source, "__FTP_Temporary_Page__");

          final List<InvertibleModificationOperation> changeSet = Importer.diffPages(origPage, modifiedPage);
View Full Code Here
407
408
409
410
411
412
413
414
415
416
417
  protected <T extends AbstractNode> T createTestNode(final Class<T> type, final PropertyMap props, final Principal user) throws FrameworkException {

    final App backendApp = StructrApp.getInstance(SecurityContext.getInstance(user, AccessMode.Backend));

    try (final Tx tx = backendApp.tx()) {

      final T result = backendApp.create(type, props);
      tx.success();

      return result;
View Full Code Here
420
421
422
423
424
425
426
427
428
429
430
  public static void clearResourceAccess() {

    final App app = StructrApp.getInstance();

    try (final Tx tx = app.tx()) {

      for (final ResourceAccess access : app.nodeQuery(ResourceAccess.class).getAsList()) {
        app.delete(access);
      }
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
  public AbstractNode getNode(final String id) {

    final SecurityContext securityContext = getWebSocket().getSecurityContext();
    final App app = StructrApp.getInstance(securityContext);

    try (final Tx tx = app.tx()) {

      final AbstractNode node = (AbstractNode)app.get(id);

      tx.success();
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
    }

    final SecurityContext securityContext = getWebSocket().getSecurityContext();
    final App app = StructrApp.getInstance(securityContext);

    try (final Tx tx = app.tx()) {

      final AbstractRelationship rel = (AbstractRelationship)app.get(id);

      tx.success();
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    final SecurityContext securityContext = getWebSocket().getSecurityContext();
    final App app                         = StructrApp.getInstance(securityContext);
    final String id                       = webSocketData.getId();

    try (final Tx tx = app.tx()) {

      final Page page                = app.get(Page.class, id);
      final List<GraphObject> result = new LinkedList<>();

      if (page != null) {
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
    final Long port                      = (Long)properties.get("port");

    if (host != null && port != null && username != null && password != null && key != null) {

      final App app    = StructrApp.getInstance();
      try (final Tx tx = app.tx()) {

        final List<SyncableInfo> syncables = CloudService.doRemote(new SingleTransmission<>(new ListSyncables(type), username, password, host, port.intValue()), new WebsocketProgressListener(getWebSocket(), key));
        final StructrWebSocket webSocket   = getWebSocket();
        if (syncables != null) {
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
    query.includeDeletedAndHidden();
    query.orTypes(DOMElement.class);
    query.orType(Content.class);

    try (final Tx tx = app.tx()) {

      resultList.addAll(query.getAsList());

      // determine which of the nodes have incoming CONTAINS relationships and are not components
      for (GraphObject obj : resultList) {
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    int count                             = 0;

    while (iterator.hasNext()) {

      count = 0;
      try (final Tx tx = app.tx()) {

        while (iterator.hasNext() && count++ < 100) {

          app.delete(iterator.next());
        }
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.