Package org.springframework.jdbc.core

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

114
115
116
117
118
119
120
121
122
123
124
    final String noCommentSql[] = removeCommentsAndSemicolons(connectionModel.getSchema(), sql);
    try {
      // run the code in a transaction
      txTemplate.execute(new TransactionCallbackWithoutResult() {
        public void doInTransactionWithoutResult(TransactionStatus status) {
          jt.batchUpdate(noCommentSql);
        }
      });
    } catch (DataAccessException e) {
      if (logger.isErrorEnabled()) {
        logger.error("data access exception", e);
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
      for(String sql : statements) {
        if(sql != null && sql.trim().length() > 0)
          listStatements.add(sql);
      }
      JdbcTemplate jt = new JdbcTemplate(this.getDataSource());
      jt.batchUpdate(listStatements.toArray(new String[]{}));
    }
  }

  /*
   * (non-Javadoc)
 
View Full Code Here
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
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
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
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
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
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
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
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
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.