Examples of batchUpdate()

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

499
500
501
502
503
504
505
506
507
508
509
                                    try {
                                        failedDatas.clear(); // 先清理
                                        processedDatas.clear();
                                        interceptor.transactionBegin(context, splitDatas, dbDialect);
                                        JdbcTemplate template = dbDialect.getJdbcTemplate();
                                        int[] affects = template.batchUpdate(sql, new BatchPreparedStatementSetter() {

                                            public void setValues(PreparedStatement ps, int idx) throws SQLException {
                                                doPreparedStatement(ps, dbDialect, lobCreator, splitDatas.get(idx));
                                            }
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

106
107
108
109
110
111
112
113
114
115
116
      throw new OmhException("Could not convert some data to JSON.", e);
    }
   
    // Add the data.
    try {
      jdbcTemplate
        .batchUpdate(
          "INSERT INTO " + DataSet.DB_NAME + " (" +
              UserBin.DB_NAME + "_id" + ", " +
              Registry.DB_NAME + "_id" + ", " +
              Data.JSON_KEY_METADATA + "_" +
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

100
101
102
103
104
105
106
107
108
109
110
                        try {
                            transactionTemplate.execute(new TransactionCallback() {

                                public Object doInTransaction(TransactionStatus status) {
                                    JdbcTemplate jdbcTemplate = dbDialect.getJdbcTemplate();
                                    return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {

                                        public void setValues(PreparedStatement ps, int idx) throws SQLException {
                                            int id = start + idx;
                                            StatementCreatorUtils.setParameterValue(ps, 1, Types.INTEGER, null, id);
                                            StatementCreatorUtils.setParameterValue(ps,
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

568
569
570
571
572
573
574
575
576
577
578
                                    try {
                                        failedDatas.clear(); // 先清理
                                        processedDatas.clear();
                                        interceptor.transactionBegin(context, splitDatas, dbDialect);
                                        JdbcTemplate template = dbDialect.getJdbcTemplate();
                                        int[] affects = template.batchUpdate(sql, new BatchPreparedStatementSetter() {

                                            public void setValues(PreparedStatement ps, int idx) throws SQLException {
                                                doPreparedStatement(ps, dbDialect, lobCreator, splitDatas.get(idx));
                                            }
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

577
578
579
580
581
582
583
584
585
586
587
                                    try {
                                        failedDatas.clear(); // 先清理
                                        processedDatas.clear();
                                        interceptor.transactionBegin(context, splitDatas, dbDialect);
                                        JdbcTemplate template = dbDialect.getJdbcTemplate();
                                        int[] affects = template.batchUpdate(sql, new BatchPreparedStatementSetter() {

                                            public void setValues(PreparedStatement ps, int idx) throws SQLException {
                                                doPreparedStatement(ps, dbDialect, lobCreator, splitDatas.get(idx));
                                            }
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

582
583
584
585
586
587
588
589
590
591
592
                                    try {
                                        failedDatas.clear(); // 先清理
                                        processedDatas.clear();
                                        interceptor.transactionBegin(context, splitDatas, dbDialect);
                                        JdbcTemplate template = dbDialect.getJdbcTemplate();
                                        int[] affects = template.batchUpdate(sql, new BatchPreparedStatementSetter() {

                                            public void setValues(PreparedStatement ps, int idx) throws SQLException {
                                                doPreparedStatement(ps, dbDialect, lobCreator, splitDatas.get(idx));
                                            }
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

594
595
596
597
598
599
600
601
602
603
604
          public void setValues(PreparedStatement ps, int i) throws SQLException {
            RowBasedReplicationContext context = endContexts.get(i);
            ps.setString(1, context.getSyncLogId());
          }
        };
        jt.batchUpdate(e.getKey(), setter);
        if (log.isDebugEnabled()) {
          log.debug("[batchDeleteSyncLog], sql = [" + e.getKey() + "], batch size="+endContexts.size());
        }
      }
    }
View Full Code Here

Examples of org.springframework.jdbc.core.JdbcTemplate.batchUpdate()

726
727
728
729
730
731
732
733
734
735
736
            RowBasedReplicationContext context = endContexts.get(i);
            ps.setTimestamp(1, getNextSyncTime(context, extraPlusTime));
            ps.setString(2, context.getSyncLogId());
          }
        };
        jt.batchUpdate(e.getKey(), setter);
        if (log.isDebugEnabled()) {
          log.debug("[batchUpdateSyncLog], sql = [" + e.getKey() + "], batch size="+endContexts.size());
        }
      }
    }
View Full Code Here

Examples of org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate.batchUpdate()

67
68
69
70
71
72
73
74
75
76
77
        try {
            txTemplate.execute(new TransactionCallbackWithoutResult() {

                @Override
                public void doInTransactionWithoutResult(TransactionStatus ts) {
                    npjt.batchUpdate(insertQuery, parameters);
                }
            });
           
            return;
        } catch (RuntimeException ex) {
View Full Code Here

Examples of org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate.batchUpdate()

104
105
106
107
108
109
110
111
112
113
114
        try {
            txTemplate.execute(new TransactionCallbackWithoutResult() {
                @Override
                public void doInTransactionWithoutResult(TransactionStatus ts) {
                    int[] affectedRows =
                            npjt.batchUpdate(insertQuery.getSql(), parameters.toArray(new MapSqlParameterSource[0]));
                   
                    int sum = 0;
                    for (int i = 0; i < affectedRows.length; ++i) {
                        sum += DatabaseUtils.getAffectedRowsNumber(affectedRows[i]);
                    }
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.