Examples of createSQLQuery()

Examples of org.hibernate.Session.createSQLQuery()

74
75
76
77
78
79
80
81
82
83
84
    }


    public Org pesquisarOrgPorCnpj(String cnpj){
        Session session = factory.openSession();
        SQLQuery query = session.createSQLQuery("SELECT {org.*} FROM org {org} WHERE cnpj = "+cnpj);

        query.addEntity("org", Org.class);

        Org org = null;
        if(query.list().size() > 0){
View Full Code Here

Examples of org.hibernate.Session.createSQLQuery()

89
90
91
92
93
94
95
96
97
98
99
    }
   

    public Org pesquisarOrgPorNome(String nome){
        Session session = factory.openSession();
        SQLQuery query = session.createSQLQuery("SELECT {org.*} FROM org {org} WHERE nome like '"+nome+"'");

        query.addEntity("org", Org.class);

        Org org = null;
        if(query.list().size() > 0){
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

84
85
86
87
88
89
90
91
92
93
94
    }

    private long getRowCount(String countQuery) {
        StatelessSession session = getSQLSession(config);

        org.hibernate.Query query = session.createSQLQuery(countQuery);
        query.setReadOnly(true);
        query.setTimeout(DataMigrator.SQL_TIMEOUT);

        long count = Long.parseLong(query.uniqueResult().toString());
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

183
184
185
186
187
188
189
190
191
192
193
        int failureCount = 0;
        while (failureCount < MAX_NUMBER_OF_FAILURES) {
            try {
                StatelessSession session = getSQLSession(config);
                session.getTransaction().begin();
                org.hibernate.Query nativeQuery = session.createSQLQuery(deleteQuery);
                nativeQuery.executeUpdate();
                session.getTransaction().commit();
                closeSQLSession(session);
                log.info("- " + table + " - Cleaned -");
            } catch (Exception e) {
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

156
157
158
159
160
161
162
163
164
165
166
            duration = metricsConfiguration.getSixHourTimeSliceDuration();
            queryString = MigrationQuery.MAX_TIMESTAMP_1D_DATA.toString();
        }

        if (duration != null && queryString != null) {
            Query query = session.createSQLQuery(queryString);

            Long timeStamp;
            Object result = query.uniqueResult();
            if(result != null){
                String queryResult = query.uniqueResult().toString();
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

44
45
46
47
48
49
50
51
52
53
54
        org.hibernate.Query nativeQuery;
        StatelessSession session = getSQLSession(config);

        if (config.isRun1HAggregateDataMigration()) {
            session.getTransaction().begin();
            nativeQuery = session.createSQLQuery(MigrationQuery.DELETE_1H_DATA.toString());
            nativeQuery.executeUpdate();
            session.getTransaction().commit();
            log.info("- RHQ_MEASUREMENT_DATA_NUM_1H - Cleaned -");
        }
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

52
53
54
55
56
57
58
59
60
61
62
            log.info("- RHQ_MEASUREMENT_DATA_NUM_1H - Cleaned -");
        }

        if (config.isRun6HAggregateDataMigration()) {
            session.getTransaction().begin();
            nativeQuery = session.createSQLQuery(MigrationQuery.DELETE_6H_DATA.toString());
            nativeQuery.executeUpdate();
            session.getTransaction().commit();
            log.info("- RHQ_MEASUREMENT_DATA_NUM_6H - Cleaned -");
        }
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

60
61
62
63
64
65
66
67
68
69
70
            log.info("- RHQ_MEASUREMENT_DATA_NUM_6H - Cleaned -");
        }

        if (config.isRun1DAggregateDataMigration()) {
            session.getTransaction().begin();
            nativeQuery = session.createSQLQuery(MigrationQuery.DELETE_1D_DATA.toString());
            nativeQuery.executeUpdate();
            session.getTransaction().commit();
            log.info("- RHQ_MEASUREMENT_DATA_NUM_1D - Cleaned -");
        }
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

70
71
72
73
74
75
76
77
78
79
80
        if (config.isRunRawDataMigration()) {
            for (String table : getRawDataTables()) {
                session.getTransaction().begin();
                String deleteAllData = String.format(MigrationQuery.DELETE_RAW_ALL_DATA.toString(), table);
                nativeQuery = session.createSQLQuery(deleteAllData);
                nativeQuery.executeUpdate();
                session.getTransaction().commit();
                log.info("- " + table + " - Cleaned -");
            }
        }
View Full Code Here

Examples of org.hibernate.StatelessSession.createSQLQuery()

109
110
111
112
113
114
115
116
117
118
119
    }

    private long getRowCount(String countQuery) {
        StatelessSession session = getSQLSession(config);

        org.hibernate.Query query = session.createSQLQuery(countQuery);
        query.setReadOnly(true);
        query.setTimeout(DataMigrator.SQL_TIMEOUT);
        long count = Long.parseLong(query.uniqueResult().toString());

        closeSQLSession(session);
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.