Package com.cloud.utils.db

Examples of com.cloud.utils.db.TransactionLegacy.start()

56
57
58
59
60
61
62
63
64
65
66
        LocalStorageHostSearch.and("MHostID", LocalStorageHostSearch.entity().getMhostid(), SearchCriteria.Op.EQ);
        LocalStorageHostSearch.and("ExportRoot", LocalStorageHostSearch.entity().getExportRoot(), SearchCriteria.Op.EQ);
        LocalStorageHostSearch.done();
        TransactionLegacy txn = TransactionLegacy.currentTxn();
        try {
            txn.start();
            SearchCriteria<SHostVO> sc = LocalStorageHostSearch.create();
            sc.setParameters("MHostID", mhostId);
            sc.setParameters("ExportRoot", storageRoot);
            return findOneBy(sc);
        } finally {
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
        SearchByTarget.and("Target", SearchByTarget.entity().getTarget(), SearchCriteria.Op.EQ);
        SearchByTarget.and("TargetID", SearchByTarget.entity().getTargetId(), SearchCriteria.Op.EQ);
        SearchByTarget.done();
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        try {
            txn.start();
            SearchCriteria<SMetaVO> sc = SearchByTarget.create();
            sc.setParameters("Target", target);
            sc.setParameters("TargetID", targetId);
            return listBy(sc);
        } finally {
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
        SearchBuilder<SMetaVO> SearchByTarget = createSearchBuilder();
        SearchByTarget.and("Target", SearchByTarget.entity().getTarget(), SearchCriteria.Op.EQ);
        SearchByTarget.and("TargetID", SearchByTarget.entity().getTargetId(), SearchCriteria.Op.EQ);
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        try {
            txn.start();
            SearchCriteria<SMetaVO> sc = SearchByTarget.create();
            sc.setParameters("Target", target);
            sc.setParameters("TargetID", targetId);
            this.remove(sc);
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
    public void add(long podId, int start, int end) {
        String insertVnet = "INSERT INTO `cloud`.`op_pod_vlan_alloc` (vlan, pod_id) VALUES ( ?, ?)";

        TransactionLegacy txn = TransactionLegacy.currentTxn();
        try {
            txn.start();
            PreparedStatement stmt = txn.prepareAutoCloseStatement(insertVnet);
            for (int i = start; i < end; i++) {
                stmt.setString(1, String.valueOf(i));
                stmt.setLong(2, podId);
                stmt.addBatch();
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
        SearchCriteria<PodVlanVO> sc = FreeVlanSearch.create();
        sc.setParameters("podId", podId);
        Date now = new Date();
        TransactionLegacy txn = TransactionLegacy.currentTxn();
        try {
            txn.start();
            PodVlanVO vo = lockOneRandomRow(sc, true);
            if (vo == null) {
                return null;
            }
View Full Code Here
730
731
732
733
734
735
736
737
738
739
740
    @Override
    @DB
    public boolean remove(Long id) {
        TransactionLegacy txn = TransactionLegacy.currentTxn();
        txn.start();
        VMInstanceVO vm = findById(id);
        if (vm != null && vm.getType() == Type.User) {
            _tagsDao.removeByIdAndType(id, ResourceObjectType.UserVm);
        }
        boolean result = super.remove(id);
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
    }

    @Override
    public boolean remove(Long id) {
        TransactionLegacy txn = TransactionLegacy.currentTxn();
        txn.start();
        ClusterVO cluster = createForUpdate();
        cluster.setName(null);
        cluster.setGuid(null);

        update(id, cluster);
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
    }

    @Override
    public void updateMap(Long vmId, List<Long> affinityGroupIds) {
        TransactionLegacy txn = TransactionLegacy.currentTxn();
        txn.start();

        SearchCriteria<AffinityGroupVMMapVO> sc = createSearchCriteria();
        sc.addAnd("instanceId", SearchCriteria.Op.EQ, vmId);
        expunge(sc);
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    @Override
    public void update(UsageVPNUserVO usage) {
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.USAGE_DB);
        PreparedStatement pstmt = null;
        try {
            txn.start();
            if (usage.getDeleted() != null) {
                pstmt = txn.prepareAutoCloseStatement(UPDATE_DELETED);
                pstmt.setString(1, DateUtil.getDateDisplayString(TimeZone.getTimeZone("GMT"), usage.getDeleted()));
                pstmt.setLong(2, usage.getAccountId());
                pstmt.setLong(3, usage.getUserId());
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    @Override
    public void update(UsageIPAddressVO usage) {
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.USAGE_DB);
        PreparedStatement pstmt = null;
        try {
            txn.start();
            if (usage.getReleased() != null) {
                pstmt = txn.prepareAutoCloseStatement(UPDATE_RELEASED);
                pstmt.setString(1, DateUtil.getDateDisplayString(TimeZone.getTimeZone("GMT"), usage.getReleased()));
                pstmt.setLong(2, usage.getAccountId());
                pstmt.setString(3, usage.getAddress());
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.