2 * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.netconf.sal.connect.netconf.sal.tx;
11 import static org.mockito.Mockito.verify;
12 import static org.mockito.Mockito.when;
14 import com.google.common.util.concurrent.CheckedFuture;
15 import com.google.common.util.concurrent.Futures;
16 import org.junit.Assert;
17 import org.junit.Before;
18 import org.junit.Test;
19 import org.mockito.Mock;
20 import org.mockito.MockitoAnnotations;
21 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
22 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
23 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadTransaction;
24 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
25 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
26 import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
27 import org.opendaylight.yangtools.yang.data.api.schema.LeafNode;
29 public class ReadWriteTxTest {
31 private DOMDataReadTransaction delegateReadTx;
33 private DOMDataWriteTransaction delegateWriteTx;
34 private ReadWriteTx tx;
37 public void setUp() throws Exception {
38 MockitoAnnotations.initMocks(this);
39 tx = new ReadWriteTx(delegateReadTx, delegateWriteTx);
43 public void submit() throws Exception {
44 final YangInstanceIdentifier id1 = TxTestUtils.getContainerId();
45 final ContainerNode containerNode = TxTestUtils.getContainerNode();
46 tx.put(LogicalDatastoreType.CONFIGURATION, id1, containerNode);
47 verify(delegateWriteTx).put(LogicalDatastoreType.CONFIGURATION, id1, containerNode);
48 final YangInstanceIdentifier id2 = TxTestUtils.getLeafId();
49 final LeafNode<String> leafNode = TxTestUtils.getLeafNode();
50 tx.merge(LogicalDatastoreType.CONFIGURATION, id2, leafNode);
51 verify(delegateWriteTx).merge(LogicalDatastoreType.CONFIGURATION, id2, leafNode);
52 tx.delete(LogicalDatastoreType.CONFIGURATION, id2);
53 verify(delegateWriteTx).delete(LogicalDatastoreType.CONFIGURATION, id2);
55 verify(delegateWriteTx).commit();
59 public void cancel() throws Exception {
61 verify(delegateWriteTx).cancel();
65 public void read() throws Exception {
66 tx.read(LogicalDatastoreType.CONFIGURATION, TxTestUtils.getContainerId());
67 verify(delegateReadTx).read(LogicalDatastoreType.CONFIGURATION, TxTestUtils.getContainerId());
71 public void exists() throws Exception {
72 final YangInstanceIdentifier id = TxTestUtils.getContainerId();
73 final CheckedFuture<Boolean, ReadFailedException> resultFuture =
74 Futures.immediateCheckedFuture(true);
75 when(delegateReadTx.exists(LogicalDatastoreType.CONFIGURATION, id)).thenReturn(resultFuture);
76 final CheckedFuture<Boolean, ReadFailedException> exists = tx.exists(LogicalDatastoreType.CONFIGURATION, id);
77 Assert.assertTrue(exists.get());
81 public void getIdentifier() throws Exception {
82 final ReadWriteTx tx2 = new ReadWriteTx(null, null);
83 Assert.assertNotEquals(tx.getIdentifier(), tx2.getIdentifier());