Package com.cloud.utils.db

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


    @Override
    @DB
    public void save(String name, String certificate, String key, String domainSuffix) {
        TransactionLegacy txn = TransactionLegacy.currentTxn();
        try {
            txn.start();

            String sql =
                "INSERT INTO keystore (`name`, `certificate`, `key`, `domain_suffix`) VALUES (?, ?, ?, ?) ON DUPLICATE KEY UPDATE `certificate`=?, `key`=?, `domain_suffix`=?";
            PreparedStatement pstmt = txn.prepareAutoCloseStatement(sql);
            pstmt.setString(1, name);
View Full Code Here


        SearchByTarget.and("TargetID", SearchByTarget.entity().getTargetId(), SearchCriteria.Op.EQ);
        SearchByTarget.done();
        Filter filter = new Filter(SAclVO.class, "grantOrder", Boolean.TRUE, null, null);
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        try {
            txn.start();
            SearchCriteria<SAclVO> sc = SearchByTarget.create();
            sc.setParameters("Target", target);
            sc.setParameters("TargetID", targetId);
            return listBy(sc, filter);
View Full Code Here

        SearchByAcl.and("TargetID", SearchByAcl.entity().getTargetId(), SearchCriteria.Op.EQ);
        SearchByAcl.and("GranteeCanonicalID", SearchByAcl.entity().getGranteeCanonicalId(), SearchCriteria.Op.EQ);
        Filter filter = new Filter(SAclVO.class, "grantOrder", Boolean.TRUE, null, null);
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        try {
            txn.start();
            SearchCriteria<SAclVO> sc = SearchByAcl.create();
            sc.setParameters("Target", target);
            sc.setParameters("TargetID", targetId);
            sc.setParameters("GranteeCanonicalID", userCanonicalId);
            return listBy(sc, filter);
View Full Code Here

        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<SAclVO> sc = SearchByTarget.create();
            sc.setParameters("Target", target);
            sc.setParameters("TargetID", targetId);
            this.remove(sc);
            if (acl != null) {
View Full Code Here

    public BucketPolicyVO getByName(String bucketName) {
        SearchBuilder<BucketPolicyVO> searchByBucket = createSearchBuilder();
        searchByBucket.and("BucketName", searchByBucket.entity().getBucketName(), SearchCriteria.Op.EQ);
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        try {
            txn.start();
            SearchCriteria<BucketPolicyVO> sc = searchByBucket.create();
            sc.setParameters("BucketName", bucketName);
            return findOneBy(sc);

        } finally {
View Full Code Here

    public void deletePolicy(String bucketName) {
        SearchBuilder<BucketPolicyVO> deleteByBucket = createSearchBuilder();
        deleteByBucket.and("BucketName", deleteByBucket.entity().getBucketName(), SearchCriteria.Op.EQ);
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        try {
            txn.start();
            SearchCriteria<BucketPolicyVO> sc = deleteByBucket.create();
            sc.setParameters("BucketName", bucketName);
            remove(sc);

        } finally {
View Full Code Here

        SearchBuilder<CloudStackServiceOfferingVO> searchByName = createSearchBuilder();
        searchByName.and("name", searchByName.entity().getName(), SearchCriteria.Op.EQ);
        searchByName.done();
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.CLOUD_DB);
        try {
            txn.start();
            SearchCriteria<CloudStackServiceOfferingVO> sc = searchByName.create();
            sc.setParameters("name", name);
            return findOneBy(sc);

        } finally {
View Full Code Here

        SearchBuilder<CloudStackServiceOfferingVO> searchByID = createSearchBuilder();
        searchByID.and("uuid", searchByID.entity().getUuid(), SearchCriteria.Op.EQ);
        searchByID.done();
        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.CLOUD_DB);
        try {
            txn.start();
            SearchCriteria<CloudStackServiceOfferingVO> sc = searchByID.create();
            sc.setParameters("uuid", id);
            return findOneBy(sc);

        } finally {
View Full Code Here

        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        SearchBuilder<SObjectItemVO> SearchByID = createSearchBuilder();
        SearchByID.and("ID", SearchByID.entity().getId(), SearchCriteria.Op.EQ);

        try {
            txn.start();
            SearchCriteria<SObjectItemVO> sc = SearchByID.create();
            sc.setParameters("ID", id);
            return findOneBy(sc);
        } finally {
            txn.close();
View Full Code Here

        TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.AWSAPI_DB);
        SearchBuilder<SObjectItemVO> SearchBySobjectID = createSearchBuilder();
        SearchBySobjectID.and("SObjectID", SearchBySobjectID.entity().getId(), SearchCriteria.Op.EQ);

        try {
            txn.start();
            SearchCriteria<SObjectItemVO> sc = SearchBySobjectID.create();
            sc.setParameters("SObjectID", sobjectID);
            return listBy(sc);
            //findOneIncludingRemovedBy(sc);
        } finally {
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.