~ubuntu-branches/ubuntu/oneiric/mysql-connector-java/oneiric

« back to all changes in this revision

Viewing changes to src/com/mysql/jdbc/RowDataDynamic.java

Committer: Bazaar Package Importer
Author(s): Michael Koch
Date: 2007-11-30 10:34:13 UTC
mfrom: (1.1.4 upstream)
Revision ID: james.westby@ubuntu.com-20071130103413-mxm4lpfrr4fnjbuj

Tags: 5.1.5+dfsg-1

http://bugs.debian.org/450718

* New upstream release. Closes: #450718.
* Add Homepage field to debian/control.

files added:
debian/README.Debian

src/com/mysql/jdbc/BufferRow.java

src/com/mysql/jdbc/ByteArrayRow.java

src/com/mysql/jdbc/CachedResultSetMetaData.java

src/com/mysql/jdbc/ConnectionImpl.java

src/com/mysql/jdbc/ConnectionLifecycleInterceptor.java

src/com/mysql/jdbc/ConnectionPropertiesImpl.java

src/com/mysql/jdbc/Extension.java

src/com/mysql/jdbc/IterateBlock.java

src/com/mysql/jdbc/JDBC4CallableStatement.java

src/com/mysql/jdbc/JDBC4ClientInfoProvider.java

src/com/mysql/jdbc/JDBC4ClientInfoProviderSP.java

src/com/mysql/jdbc/JDBC4CommentClientInfoProvider.java

src/com/mysql/jdbc/JDBC4Connection.java

src/com/mysql/jdbc/JDBC4DatabaseMetaData.java

src/com/mysql/jdbc/JDBC4DatabaseMetaDataUsingInfoSchema.java

src/com/mysql/jdbc/JDBC4MysqlSQLXML.java

src/com/mysql/jdbc/JDBC4NClob.java

src/com/mysql/jdbc/JDBC4PreparedStatement.java

src/com/mysql/jdbc/JDBC4PreparedStatementHelper.java

src/com/mysql/jdbc/JDBC4ResultSet.java

src/com/mysql/jdbc/JDBC4ServerPreparedStatement.java

src/com/mysql/jdbc/JDBC4UpdatableResultSet.java

src/com/mysql/jdbc/LoadBalancingConnectionProxy.java

src/com/mysql/jdbc/ParameterBindings.java

src/com/mysql/jdbc/PingTarget.java

src/com/mysql/jdbc/ResultSetImpl.java

src/com/mysql/jdbc/ResultSetInternalMethods.java

src/com/mysql/jdbc/ResultSetRow.java

src/com/mysql/jdbc/RowDataCursor.java

src/com/mysql/jdbc/RowDataKeyset.java

src/com/mysql/jdbc/StatementImpl.java

src/com/mysql/jdbc/StatementInterceptor.java

src/com/mysql/jdbc/StreamingNotifiable.java

src/com/mysql/jdbc/configs/5-0-Compat.properties

src/com/mysql/jdbc/configs/coldFusion.properties

src/com/mysql/jdbc/exceptions/MySQLStatementCancelledException.java

src/com/mysql/jdbc/exceptions/NotYetImplementedException.java

src/com/mysql/jdbc/exceptions/jdbc4

src/com/mysql/jdbc/exceptions/jdbc4/CommunicationsException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLDataException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLIntegrityConstraintViolationException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLInvalidAuthorizationSpecException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLNonTransientConnectionException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLNonTransientException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLSyntaxErrorException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLTimeoutException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLTransactionRollbackException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLTransientConnectionException.java

src/com/mysql/jdbc/exceptions/jdbc4/MySQLTransientException.java

src/com/mysql/jdbc/interceptors

src/com/mysql/jdbc/interceptors/ResultSetScannerInterceptor.java

src/com/mysql/jdbc/interceptors/ServerStatusDiffInterceptor.java

src/com/mysql/jdbc/interceptors/SessionAssociationInterceptor.java

src/com/mysql/jdbc/jdbc2/optional/JDBC4CallableStatementWrapper.java

src/com/mysql/jdbc/jdbc2/optional/JDBC4ConnectionWrapper.java

src/com/mysql/jdbc/jdbc2/optional/JDBC4PreparedStatementWrapper.java

src/com/mysql/jdbc/jdbc2/optional/JDBC4StatementWrapper.java

src/testsuite/simple/ResultSetTest.java

src/testsuite/simple/jdbc4

src/testsuite/simple/jdbc4/StatementsTest.java

src/testsuite/ssl-test-certs

src/testsuite/ssl-test-certs/ca-cert.pem

src/testsuite/ssl-test-certs/ca-key.pem

src/testsuite/ssl-test-certs/server-cert.pem

src/testsuite/ssl-test-certs/server-key.pem

src/testsuite/ssl-test-certs/server-req.pem

src/testsuite/ssl-test-certs/test-cert-store

files removed:
debug

docs/release-test-output

src/com/mysql/jdbc/CursorRowProvider.java

src/com/mysql/jdbc/ResultSet.java

files modified:
CHANGES

EXCEPTIONS-CONNECTOR-J

build.xml

debian/changelog

debian/control

debian/rules

docs/README

docs/README.txt

docs/connector-j.html

docs/connector-j.pdf

src/com/mysql/jdbc/Blob.java

src/com/mysql/jdbc/BlobFromLocator.java

src/com/mysql/jdbc/Buffer.java

src/com/mysql/jdbc/CallableStatement.java

src/com/mysql/jdbc/CharsetMapping.java

src/com/mysql/jdbc/Clob.java

src/com/mysql/jdbc/CommunicationsException.java

src/com/mysql/jdbc/Connection.java

src/com/mysql/jdbc/ConnectionFeatureNotAvailableException.java

src/com/mysql/jdbc/ConnectionProperties.java

src/com/mysql/jdbc/Constants.java

src/com/mysql/jdbc/DatabaseMetaData.java

src/com/mysql/jdbc/DatabaseMetaDataUsingInfoSchema.java

src/com/mysql/jdbc/DocsConnectionPropsHelper.java

src/com/mysql/jdbc/EscapeProcessor.java

src/com/mysql/jdbc/EscapeProcessorResult.java

src/com/mysql/jdbc/EscapeTokenizer.java

src/com/mysql/jdbc/ExportControlled.java

src/com/mysql/jdbc/Field.java

src/com/mysql/jdbc/LocalizedErrorMessages.properties

src/com/mysql/jdbc/MysqlDefs.java

src/com/mysql/jdbc/MysqlIO.java

src/com/mysql/jdbc/MysqlParameterMetadata.java

src/com/mysql/jdbc/NonRegisteringDriver.java

src/com/mysql/jdbc/NotUpdatable.java

src/com/mysql/jdbc/PreparedStatement.java

src/com/mysql/jdbc/ReplicationConnection.java

src/com/mysql/jdbc/ResultSetMetaData.java

src/com/mysql/jdbc/RowData.java

src/com/mysql/jdbc/RowDataDynamic.java

src/com/mysql/jdbc/RowDataStatic.java

src/com/mysql/jdbc/SQLError.java

src/com/mysql/jdbc/ServerPreparedStatement.java

src/com/mysql/jdbc/SingleByteCharsetConverter.java

src/com/mysql/jdbc/StandardSocketFactory.java

src/com/mysql/jdbc/Statement.java

src/com/mysql/jdbc/StringUtils.java

src/com/mysql/jdbc/TimeUtil.java

src/com/mysql/jdbc/UpdatableResultSet.java

src/com/mysql/jdbc/Util.java

src/com/mysql/jdbc/configs/3-0-Compat.properties

src/com/mysql/jdbc/configs/maxPerformance.properties

src/com/mysql/jdbc/integration/c3p0/MysqlConnectionTester.java

src/com/mysql/jdbc/integration/jboss/MysqlValidConnectionChecker.java

src/com/mysql/jdbc/jdbc2/optional/CallableStatementWrapper.java

src/com/mysql/jdbc/jdbc2/optional/ConnectionWrapper.java

src/com/mysql/jdbc/jdbc2/optional/MysqlDataSource.java

src/com/mysql/jdbc/jdbc2/optional/MysqlDataSourceFactory.java

src/com/mysql/jdbc/jdbc2/optional/MysqlPooledConnection.java

src/com/mysql/jdbc/jdbc2/optional/MysqlXAConnection.java

src/com/mysql/jdbc/jdbc2/optional/MysqlXADataSource.java

src/com/mysql/jdbc/jdbc2/optional/PreparedStatementWrapper.java

src/com/mysql/jdbc/jdbc2/optional/StatementWrapper.java

src/com/mysql/jdbc/jdbc2/optional/SuspendableXAConnection.java

src/com/mysql/jdbc/jdbc2/optional/WrapperBase.java

src/com/mysql/jdbc/log/LogUtils.java

src/com/mysql/jdbc/profiler/ProfileEventSink.java

src/com/mysql/jdbc/profiler/ProfilerEvent.java

src/com/mysql/jdbc/util/PropertiesDocGenerator.java

src/com/mysql/jdbc/util/ServerController.java

src/com/mysql/jdbc/util/VersionFSHierarchyMaker.java

src/doc/sources/errorMapToDocbook.xsl

src/testsuite/BaseTestCase.java

src/testsuite/regression/CallableStatementRegressionTest.java

src/testsuite/regression/ConnectionRegressionTest.java

src/testsuite/regression/DataSourceRegressionTest.java

src/testsuite/regression/EscapeProcessorRegressionTest.java

src/testsuite/regression/MetaDataRegressionTest.java

src/testsuite/regression/ResultSetRegressionTest.java

src/testsuite/regression/StatementRegressionTest.java

src/testsuite/regression/StressRegressionTest.java

src/testsuite/regression/StringRegressionTest.java

src/testsuite/regression/SubqueriesRegressionTest.java

src/testsuite/simple/BlobTest.java

src/testsuite/simple/CallableStatementTest.java

src/testsuite/simple/CharsetTests.java

src/testsuite/simple/ConnectionTest.java

src/testsuite/simple/DataSourceTest.java

src/testsuite/simple/MetadataTest.java

src/testsuite/simple/StatementsTest.java

Show diffs side-by-side

added added

removed removed

src/com/mysql/jdbc/RowDataDynamic.java

This program is free software; you can redistribute it and/or modify

it under the terms of version 2 of the GNU General Public License as

* Allows streaming of MySQL data.

* @author dgan

* @version $Id: RowDataDynamic.java 4891 2006-02-03 19:10:02Z mmatthews $

* @version $Id: RowDataDynamic.java 6454 2007-06-21 17:03:53Z mmatthews $

public class RowDataDynamic implements RowData {

// ~ Instance fields

// --------------------------------------------------------

class OperationNotSupportedException extends SQLException {

OperationNotSupportedException() {

private int columnCount;

private Field[] fields;

private Field[] metadata;

private int index = -1;

private boolean isBinaryEncoded = false;

private Object[] nextRow;

private ResultSetRow nextRow;

private ResultSet owner;

private ResultSetImpl owner;

private boolean streamerClosed = false;

private boolean wasEmpty = false; // we don't know until we attempt to traverse

// ~ Methods

// ----------------------------------------------------------------

private boolean useBufferRowExplicit;

/**

* Creates a new RowDataDynamic object.

* @param io

* the connection to MySQL that this data is coming from

* @param fields

* the fields that describe this data

* @param metadata

* the metadata that describe this data

* @param isBinaryEncoded

* is this data in native format?

* @param colCount

this.io = io;

this.columnCount = colCount;

this.isBinaryEncoded = isBinaryEncoded;

this.fields = fields;

nextRecord();

this.metadata = fields;

this.useBufferRowExplicit = MysqlIO.useBufferRowExplicit(this.metadata);

}

/**

100

* @throws SQLException

101

* if a database error occurs

102

103

public void addRow(byte[][] row) throws SQLException {

103

public void addRow(ResultSetRow row) throws SQLException {

104

notSupported();

105

}

106

141

* if a database error occurs

142

143

public void close() throws SQLException {

144

// Belt and suspenders here - if we don't

145

// have a reference to the connection

146

// it's more than likely dead/gone and we

147

// won't be able to consume rows anyway

148

149

Object mutex = this;

150

151

ConnectionImpl conn = null;

152

153

if (this.owner != null) {

154

conn = this.owner.connection;

155

156

if (conn != null) {

157

mutex = conn.getMutex();

158

}

159

}

144

160

145

161

boolean hadMore = false;

146

162

int howMuchMore = 0;

147

163

148

// drain the rest of the records.

149

while (this.hasNext()) {

150

this.next();

151

hadMore = true;

152

howMuchMore++;

153

154

if (howMuchMore % 100 == 0) {

155

Thread.yield();

156

}

157

}

158

159

if (this.owner != null) {

160

Connection conn = this.owner.connection;

161

162

if (conn != null && conn.getUseUsageAdvisor()) {

163

if (hadMore) {

164

165

ProfileEventSink eventSink = ProfileEventSink

166

.getInstance(conn);

167

168

eventSink

169

.consumeEvent(new ProfilerEvent(

170

ProfilerEvent.TYPE_WARN,

171

"", //$NON-NLS-1$

172

this.owner.owningStatement == null ? "N/A" : this.owner.owningStatement.currentCatalog, //$NON-NLS-1$

173

this.owner.connectionId,

174

this.owner.owningStatement == null ? -1

175

: this.owner.owningStatement

176

.getId(),

177

-1,

178

System.currentTimeMillis(),

179

180

null,

181

null,

182

Messages.getString("RowDataDynamic.2") //$NON-NLS-1$

183

+ howMuchMore

184

+ Messages

185

.getString("RowDataDynamic.3") //$NON-NLS-1$

186

+ Messages

187

.getString("RowDataDynamic.4") //$NON-NLS-1$

188

+ Messages

189

.getString("RowDataDynamic.5") //$NON-NLS-1$

190

+ Messages

191

.getString("RowDataDynamic.6") //$NON-NLS-1$

192

+ this.owner.pointOfOrigin));

193

}

194

}

195

}

196

197

this.fields = null;

164

synchronized (mutex) {

165

// drain the rest of the records.

166

while (next() != null) {

167

hadMore = true;

168

howMuchMore++;

169

170

if (howMuchMore % 100 == 0) {

171

Thread.yield();

172

}

173

}

174

175

if (conn != null) {

176

if (!conn.getClobberStreamingResults() &&

177

conn.getNetTimeoutForStreamingResults() > 0) {

178

String oldValue = conn

179

.getServerVariable("net_write_timeout");

180

181

if (oldValue == null || oldValue.length() == 0) {

182

oldValue = "60"; // the current default

183

}

184

185

this.io.clearInputStream();

186

187

java.sql.Statement stmt = null;

188

189

try {

190

stmt = conn.createStatement();

191

stmt.executeUpdate("SET net_write_timeout=" + oldValue);

192

} finally {

193

if (stmt != null) {

194

stmt.close();

195

}

196

}

197

}

198

199

if (conn.getUseUsageAdvisor()) {

200

if (hadMore) {

201

202

ProfileEventSink eventSink = ProfileEventSink

203

.getInstance(conn);

204

205

eventSink

206

.consumeEvent(new ProfilerEvent(

207

ProfilerEvent.TYPE_WARN,

208

"", //$NON-NLS-1$

209

this.owner.owningStatement == null ? "N/A" : this.owner.owningStatement.currentCatalog, //$NON-NLS-1$

210

this.owner.connectionId,

211

this.owner.owningStatement == null ? -1

212

: this.owner.owningStatement

213

.getId(),

214

-1,

215

System.currentTimeMillis(),

216

217

Constants.MILLIS_I18N,

218

null,

219

null,

220

Messages.getString("RowDataDynamic.2") //$NON-NLS-1$

221

+ howMuchMore

222

+ Messages

223

.getString("RowDataDynamic.3") //$NON-NLS-1$

224

+ Messages

225

.getString("RowDataDynamic.4") //$NON-NLS-1$

226

+ Messages

227

.getString("RowDataDynamic.5") //$NON-NLS-1$

228

+ Messages

229

.getString("RowDataDynamic.6") //$NON-NLS-1$

230

+ this.owner.pointOfOrigin));

231

}

232

}

233

}

234

}

235

236

this.metadata = null;

198

237

this.owner = null;

199

238

}

200

239

207

246

* @throws SQLException

208

247

* if a database error occurs

209

248

210

public Object[] getAt(int ind) throws SQLException {

249

public ResultSetRow getAt(int ind) throws SQLException {

211

250

notSupported();

212

251

213

252

return null;

229

268

/**

230

269

* @see com.mysql.jdbc.RowData#getOwner()

231

270

232

public ResultSet getOwner() {

271

public ResultSetInternalMethods getOwner() {

233

272

return this.owner;

234

273

}

235

274

343

382

* @throws SQLException

344

383

* if a database error occurs

345

384

346

public Object[] next() throws SQLException {

347

if (this.index != Integer.MAX_VALUE) {

348

this.index++;

349

}

385

public ResultSetRow next() throws SQLException {

386

350

387

351

Object[] ret = this.nextRow;

352

388

nextRecord();

353

389

354

return ret;

390

if (this.nextRow == null && !this.streamerClosed) {

391

this.io.closeStreamer(this);

392

this.streamerClosed = true;

393

}

394

395

if (this.nextRow != null) {

396

if (this.index != Integer.MAX_VALUE) {

397

this.index++;

398

}

399

}

400

401

return this.nextRow;

355

402

}

356

403

404

357

405

private void nextRecord() throws SQLException {

358

406

359

407

try {

360

if (!this.isAtEnd) {

361

362

this.nextRow = this.io.nextRow(this.fields, this.columnCount,

408

if (!this.isAtEnd) {

409

this.nextRow = this.io.nextRow(this.metadata, this.columnCount,

363

410

this.isBinaryEncoded,

364

java.sql.ResultSet.CONCUR_READ_ONLY);

411

java.sql.ResultSet.CONCUR_READ_ONLY, true,

412

this.useBufferRowExplicit, true, null);

365

413

366

414

if (this.nextRow == null) {

367

415

this.isAtEnd = true;

416

417

if (this.index == -1) {

418

this.wasEmpty = true;

419

}

368

420

}

369

421

} else {

370

422

this.isAfterEnd = true;

371

423

}

372

424

} catch (SQLException sqlEx) {

425

if (sqlEx instanceof StreamingNotifiable) {

426

((StreamingNotifiable)sqlEx).setWasStreamingResults();

427

}

428

373

429

// don't wrap SQLExceptions

374

430

throw sqlEx;

375

431

} catch (Exception ex) {

402

458

notSupported();

403

459

}

404

460

405

// ~ Inner Classes

406

// ----------------------------------------------------------

407

408

461

/**

409

462

* Moves the current position in the result set to the given row number.

410

463

418

471

}

419

472

420

473

/**

421

* @see com.mysql.jdbc.RowData#setOwner(com.mysql.jdbc.ResultSet)

474

* @see com.mysql.jdbc.RowData#setOwner(com.mysql.jdbc.ResultSetInternalMethods)

422

475

423

public void setOwner(ResultSet rs) {

476

public void setOwner(ResultSetImpl rs) {

424

477

this.owner = rs;

425

478

}

426

479

433

486

return RESULT_SET_SIZE_UNKNOWN;

434

487

}

435

488

489

public boolean wasEmpty() {

490

return this.wasEmpty;

491

}

492

493

public void setMetadata(Field[] metadata) {

494

this.metadata = metadata;

495

}

436

496

}

Older »