Class ConnectionImpl

java.lang.Object

com.mysql.jdbc.ConnectionPropertiesImpl

com.mysql.jdbc.ConnectionImpl

All Implemented Interfaces:

Connection, ConnectionProperties, MySQLConnection, Serializable, AutoCloseable, Connection, Wrapper

Direct Known Subclasses:

JDBC4Connection

public class ConnectionImpl
extends ConnectionPropertiesImpl
implements MySQLConnection

A Connection represents a session with a specific database. Within the context of a Connection, SQL statements are executed and results are returned.

A Connection's database is able to provide information describing its tables, its supported SQL grammar, its stored procedures, the capabilities of this connection, etc. This information is obtained with the getMetaData method.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ConnectionImpl.CompoundCacheKey	Used as a key for caching callable statements which (may) depend on current catalog...In 5.0.x, they don't (currently), but stored procedure names soon will, so current catalog is a (hidden) component of the name.
class	ConnectionImpl.ExceptionInterceptorChain

Nested classes/interfaces inherited from class ConnectionPropertiesImpl

ConnectionPropertiesImpl.BooleanConnectionProperty, ConnectionPropertiesImpl.ConnectionProperty, ConnectionPropertiesImpl.IntegerConnectionProperty, ConnectionPropertiesImpl.LongConnectionProperty, ConnectionPropertiesImpl.MemorySizeConnectionProperty, ConnectionPropertiesImpl.StringConnectionProperty, ConnectionPropertiesImpl.XmlMap

Field Summary

Fields

Modifier and Type	Field	Description
static Map<?,?>	charsetMap	The mapping between MySQL charset names and Java charset names.
protected static final String	DEFAULT_LOGGER_CLASS	Default logger class name
Map<Integer,String>	indexToCustomMysqlCharset
static final String	JDBC_LOCAL_CHARACTER_SET_RESULTS
protected Properties	props	Properties for this connection specified by user
protected com.mysql.jdbc.util.LRUCache<String, CachedResultSetMetaData>	resultSetMetadataCache	Cache of ResultSet metadata
protected static Map<?,?>	roundRobinStatsMap

Fields inherited from class ConnectionPropertiesImpl

characterEncodingIsAliasForSjis, largeRowSizeThreshold, traceProtocol, ZERO_DATETIME_BEHAVIOR_CONVERT_TO_NULL, ZERO_DATETIME_BEHAVIOR_EXCEPTION, ZERO_DATETIME_BEHAVIOR_ROUND

Fields inherited from interface Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectionImpl()	' For the delegate only
	ConnectionImpl(String hostToConnectTo, int portToConnectTo, Properties info, String databaseToConnectTo, String url)	Creates a connection to a MySQL Server.

Method Summary

Modifier and Type	Method	Description
void	abort(Executor executor)	Terminates an open connection.
void	abortInternal()	Clobbers the physical network connection and marks this connection as closed.
protected static SQLException	appendMessageToException(SQLException sqlEx, String messageToAppend, ExceptionInterceptor interceptor)
void	changeUser(String userName, String newPassword)	Changes the user on this connection by performing a re-authentication.
void	checkClosed()
void	clearHasTriedMaster()	Deprecated.
void	clearWarnings()	After this call, getWarnings returns null until a new warning is reported for this connection.
PreparedStatement	clientPrepareStatement(String sql)	Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	clientPrepareStatement(String sql, int autoGenKeyIndex)	Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	clientPrepareStatement(String sql, int[] autoGenKeyIndexes)	Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	clientPrepareStatement(String sql, int resultSetType, int resultSetConcurrency)	Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	clientPrepareStatement(String sql, int resultSetType, int resultSetConcurrency, boolean processEscapeCodesIfNeeded)
PreparedStatement	clientPrepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)	Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	clientPrepareStatement(String sql, String[] autoGenKeyColNames)	Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
void	close()	In some cases, it is desirable to immediately release a Connection's database and JDBC resources instead of waiting for them to be automatically released (cant think why off the top of my head) Note: A Connection is automatically closed when it is garbage collected.
void	commit()	The method commit() makes all changes made since the previous commit/rollback permanent and releases any database locks currently held by the Connection.
void	createNewIO(boolean isForReconnect)	Creates an IO channel to the server
Statement	createStatement()	SQL statements without parameters are normally executed using Statement objects.
Statement	createStatement(int resultSetType, int resultSetConcurrency)	JDBC 2.0 Same as createStatement() above, but allows the default result set type and result set concurrency type to be overridden.
Statement	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
void	decachePreparedStatement(ServerPreparedStatement pstmt)
void	dumpTestcaseQuery(String query)
Connection	duplicate()
ResultSetInternalMethods	execSQL(StatementImpl callingStatement, String sql, int maxRows, Buffer packet, int resultSetType, int resultSetConcurrency, boolean streamResults, String catalog, Field[] cachedMetadata)	Send a query to the server.
ResultSetInternalMethods	execSQL(StatementImpl callingStatement, String sql, int maxRows, Buffer packet, int resultSetType, int resultSetConcurrency, boolean streamResults, String catalog, Field[] cachedMetadata, boolean isBatch)
String	extractSqlFromPacket(String possibleSqlQuery, Buffer queryPacket, int endOfQueryPacketPosition)
StringBuilder	generateConnectionCommentBlock(StringBuilder buf)
MySQLConnection	getActiveMySQLConnection()
int	getActiveStatementCount()	Returns the number of statements active on this connection, which haven't been .close()d.
boolean	getAutoCommit()	Gets the current auto-commit state
int	getAutoIncrementIncrement()	Returns the -session- value of 'auto_increment_increment' from the server if it exists, or '1' if not.
CachedResultSetMetaData	getCachedMetaData(String sql)	Returns cached metadata (or null if not cached) for the given query, which must match _exactly_.
Calendar	getCalendarInstanceForSessionOrNew()	Optimization to only use one calendar per-session, or calculate it for each call, depending on user configuration
Timer	getCancelTimer()
String	getCatalog()	Return the connections current catalog name, or null if no catalog name is set, or we dont support catalogs.
String	getCharacterSetMetadata()
SingleByteCharsetConverter	getCharsetConverter(String javaEncodingName)	Returns the locally mapped instance of a charset converter (to avoid overhead of static synchronization).
String	getCharsetNameForIndex(int charsetIndex)	Deprecated. replaced by getEncodingForIndex(int charsetIndex)
Object	getConnectionMutex()
TimeZone	getDefaultTimeZone()
String	getEncodingForIndex(int charsetIndex)	Returns the Java character encoding name for the given MySQL server charset index
String	getErrorMessageEncoding()
ExceptionInterceptor	getExceptionInterceptor()
int	getHoldability()
String	getHost()
String	getHostPortPair()
long	getId()
long	getIdleFor()	NOT JDBC-Compliant, but clients can use this method to determine how long this connection has been idle.
protected static Connection	getInstance(String hostToConnectTo, int portToConnectTo, Properties info, String databaseToConnectTo, String url)	Creates a connection instance -- We need to provide factory-style methods so we can support both JDBC3 (and older) and JDBC4 runtimes, otherwise the class verifier complains when it tries to load JDBC4-only interface classes that are present in JDBC4 method signatures.
MysqlIO	getIO()	Returns the IO channel to the server
MySQLConnection	getLoadBalanceSafeProxy()	Deprecated. replaced by getMultiHostSafeProxy()
com.mysql.jdbc.log.Log	getLog()	Returns the log mechanism that should be used to log information from/for this Connection.
int	getMaxBytesPerChar(Integer charsetIndex, String javaCharsetName)
int	getMaxBytesPerChar(String javaCharsetName)
DatabaseMetaData	getMetaData()	A connection's database is able to provide information describing its tables, its supported SQL grammar, its stored procedures, the capabilities of this connection, etc.
Statement	getMetadataSafeStatement()
Statement	getMetadataSafeStatement(int maxRows)
MySQLConnection	getMultiHostSafeProxy()
int	getNetBufferLength()	Returns the packet buffer size the MySQL server reported upon connection
int	getNetworkTimeout()
protected static int	getNextRoundRobinHostIndex(String url, List<?> hostList)
com.mysql.jdbc.profiler.ProfilerEventHandler	getProfilerEventHandlerInstance()
Properties	getProperties()	Returns the parsed and passed in properties for this connection.
String	getQueryTimingUnits()
boolean	getRequiresEscapingEncoder()
String	getSchema()
String	getServerCharacterEncoding()	Deprecated. replaced by getServerCharset()
String	getServerCharset()	Returns the server's character set
int	getServerMajorVersion()
int	getServerMinorVersion()
int	getServerSubMinorVersion()
TimeZone	getServerTimezoneTZ()	Returns the TimeZone that represents the configured timezone for the server.
String	getServerVariable(String variableName)
String	getServerVersion()
Calendar	getSessionLockedCalendar()
int	getSessionMaxRows()	Returns the sql select limit max-rows for this session.
String	getStatementComment()	Returns the comment that will be prepended to all statements sent to the server.
List<StatementInterceptorV2>	getStatementInterceptorsInstances()
int	getTransactionIsolation()	Get this Connection's current transaction isolation mode.
Map<String,Class<?>>	getTypeMap()	JDBC 2.0 Get the type-map object associated with this connection.
String	getURL()
String	getUser()
Calendar	getUtcCalendar()
SQLWarning	getWarnings()	The first warning reported by calls on this Connection is returned.
boolean	hasSameProperties(Connection c)	Does this connection have the same properties as another?
boolean	hasTriedMaster()	Deprecated.
void	incrementNumberOfPreparedExecutes()
void	incrementNumberOfPrepares()
void	incrementNumberOfResultSetsCreated()
void	initializeExtension(Extension ex)
void	initializeResultsMetadataFromCache(String sql, CachedResultSetMetaData cachedMetaData, ResultSetInternalMethods resultSet)	Caches CachedResultSetMetaData that has been placed in the cache using the given SQL as a key.
void	initializeSafeStatementInterceptors()
boolean	isAbonormallyLongQuery(long millisOrNanos)	Update statistics that allows the driver to determine if a query is slow enough to be logged, and return the estimation result for millisOrNanos value.
boolean	isClientTzUTC()
boolean	isClosed()
boolean	isCursorFetchEnabled()
boolean	isInGlobalTx()	Is this connection currently a participant in an XA transaction?
boolean	isMasterConnection()	Is this connection connected to the first host in the list if there is a list of servers in the URL?
boolean	isNoBackslashEscapesSet()	Is the server in a sql_mode that doesn't allow us to use \\ to escape things?
boolean	isProxySet()
boolean	isQueryCacheEnabled()
boolean	isReadInfoMsgEnabled()
boolean	isReadOnly()	Tests to see if the connection is in Read Only Mode.
boolean	isReadOnly(boolean useSessionStatus)	Tests to see if the connection is in Read Only Mode.
boolean	isRunningOnJDK13()
boolean	isSameResource(Connection otherConnection)	Does this connection have the same resource name as the given connection (for XA)?
boolean	isServerLocal()	Is the server this connection is connected to "local" (i.e. same host) as the application?
boolean	isServerTruncatesFracSecs()
boolean	isServerTzUTC()
boolean	lowerCaseTableNames()	Is the server configured to use lower-case table names only?
String	nativeSQL(String sql)	A driver may convert the JDBC sql grammar into its system's native SQL grammar prior to sending it; nativeSQL returns the native form of the statement that the driver would have sent.
boolean	parserKnowsUnicode()	Does the server this connection is connected to support unicode?
void	ping()	Detect if the connection is still good
void	pingInternal(boolean checkForClosedConnection, int timeoutMillis)
CallableStatement	prepareCall(String sql)
CallableStatement	prepareCall(String sql, int resultSetType, int resultSetConcurrency)	JDBC 2.0 Same as prepareCall() above, but allows the default result set type and result set concurrency type to be overridden.
CallableStatement	prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
PreparedStatement	prepareStatement(String sql)	A SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object.
PreparedStatement	prepareStatement(String sql, int autoGenKeyIndex)
PreparedStatement	prepareStatement(String sql, int[] autoGenKeyIndexes)
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency)	JDBC 2.0 Same as prepareStatement() above, but allows the default result set type and result set concurrency type to be overridden.
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
PreparedStatement	prepareStatement(String sql, String[] autoGenKeyColNames)
void	realClose(boolean calledExplicitly, boolean issueRollback, boolean skipLocalTeardown, Throwable reason)	Closes connection and frees resources.
void	recachePreparedStatement(ServerPreparedStatement pstmt)
void	registerQueryExecutionTime(long queryTimeMs)
void	registerStatement(Statement stmt)	Register a Statement instance as open.
void	releaseSavepoint(Savepoint arg0)
protected void	reportMetricsIfNeeded()	Reports currently collected metrics if this feature is enabled and the timeout has passed.
void	reportNumberOfTablesAccessed(int numTablesAccessed)
void	reportQueryTime(long millisOrNanos)
void	resetServerState()	Resets the server-side state of this connection.
void	rollback()	The method rollback() drops all changes made since the previous commit/rollback and releases any database locks currently held by the Connection.
void	rollback(Savepoint savepoint)
PreparedStatement	serverPrepareStatement(String sql)	Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	serverPrepareStatement(String sql, int autoGenKeyIndex)	Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	serverPrepareStatement(String sql, int[] autoGenKeyIndexes)	Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	serverPrepareStatement(String sql, int resultSetType, int resultSetConcurrency)	Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	serverPrepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)	Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
PreparedStatement	serverPrepareStatement(String sql, String[] autoGenKeyColNames)	Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.
boolean	serverSupportsConvertFn()
void	setAutoCommit(boolean autoCommitFlag)	If a connection is in auto-commit mode, than all its SQL statements will be executed and committed as individual transactions.
void	setCatalog(String catalog)	A sub-space of this Connection's database may be selected by setting a catalog name.
void	setFailedOver(boolean flag)
void	setHoldability(int arg0)
void	setInGlobalTx(boolean flag)	Set the state of being in a global (XA) transaction.
void	setNetworkTimeout(Executor executor, int milliseconds)
void	setPreferSlaveDuringFailover(boolean flag)	Deprecated.
void	setProfilerEventHandlerInstance(com.mysql.jdbc.profiler.ProfilerEventHandler h)
void	setProxy(MySQLConnection proxy)
void	setReadInfoMsgEnabled(boolean flag)
void	setReadOnly(boolean readOnlyFlag)	You can put a connection in read-only mode as a hint to enable database optimizations Note: setReadOnly cannot be called while in the middle of a transaction
void	setReadOnlyInternal(boolean readOnlyFlag)
Savepoint	setSavepoint()
Savepoint	setSavepoint(String name)
void	setSchema(String schema)
void	setSessionMaxRows(int max)	Sets the sql select limit max-rows for this session if different from current.
void	setStatementComment(String comment)	Sets the comment that will be prepended to all statements sent to the server.
void	setTransactionIsolation(int level)
void	setTypeMap(Map<String,Class<?>> map)	JDBC 2.0 Install a type-map object as the default type-map for this connection
void	shutdownServer()	Used by MiniAdmin to shutdown a MySQL server
boolean	storesLowerCaseTableName()
boolean	supportsIsolationLevel()	Does the server this connection is connected to support isolation levels?
boolean	supportsQuotedIdentifiers()	Does the server this connection is connected to support quoted identifiers?
boolean	supportsTransactions()	Does the server this connection is connected to support transactions?
void	throwConnectionClosedException()
void	transactionBegun()
void	transactionCompleted()
void	unregisterStatement(Statement stmt)	Remove the given statement from the list of open statements
void	unSafeStatementInterceptors()
boolean	useAnsiQuotedIdentifiers()
boolean	versionMeetsMinimum(int major, int minor, int subminor)	Does the server this connection is connected to meet or exceed the given version?

Methods inherited from class ConnectionPropertiesImpl

exposeAsDriverPropertyInfo, exposeAsDriverPropertyInfoInternal, exposeAsProperties, exposeAsProperties, exposeAsXml, getAllowLoadLocalInfile, getAllowMasterDownConnections, getAllowMultiQueries, getAllowNanAndInf, getAllowPublicKeyRetrieval, getAllowSlaveDownConnections, getAllowUrlInLocalInfile, getAlwaysSendSetIsolation, getAuthenticationPlugins, getAutoClosePStmtStreams, getAutoDeserialize, getAutoGenerateTestcaseScript, getAutoReconnectForPools, getAutoSlowLog, getBlobsAreStrings, getBlobSendChunkSize, getCacheCallableStatements, getCacheCallableStmts, getCacheDefaultTimezone, getCachePreparedStatements, getCachePrepStmts, getCacheResultSetMetadata, getCacheServerConfiguration, getCallableStatementCacheSize, getCallableStmtCacheSize, getCapitalizeTypeNames, getCharacterSetResults, getClientCertificateKeyStorePassword, getClientCertificateKeyStoreType, getClientCertificateKeyStoreUrl, getClientInfoProvider, getClobberStreamingResults, getClobCharacterEncoding, getCompensateOnDuplicateKeyUpdateCounts, getConnectionAttributes, getConnectionCollation, getConnectionLifecycleInterceptors, getConnectTimeout, getContinueBatchOnError, getCreateDatabaseIfNotExist, getDefaultAuthenticationPlugin, getDefaultFetchSize, getDetectCustomCollations, getDisabledAuthenticationPlugins, getDisconnectOnExpiredPasswords, getDontCheckOnDuplicateKeyUpdateInSQL, getDontTrackOpenResources, getDumpMetadataOnColumnNotFound, getDumpQueriesOnException, getDynamicCalendars, getElideSetAutoCommits, getEmptyStringsConvertToZero, getEmulateLocators, getEmulateUnsupportedPstmts, getEnabledSSLCipherSuites, getEnabledTLSProtocols, getEnableEscapeProcessing, getEnablePacketDebug, getEnableQueryTimeouts, getEncoding, getExceptionInterceptors, getExplainSlowQueries, getFailOverReadOnly, getFunctionsNeverReturnBlobs, getGatherPerfMetrics, getGatherPerformanceMetrics, getGenerateSimpleParameterMetadata, getGetProceduresReturnsFunctions, getHighAvailability, getHoldResultsOpenOverStatementClose, getIgnoreNonTxTables, getIncludeInnodbStatusInDeadlockExceptions, getIncludeThreadDumpInDeadlockExceptions, getIncludeThreadNamesAsStatementComment, getInitialTimeout, getInteractiveClient, getIsInteractiveClient, getJdbcCompliantTruncation, getJdbcCompliantTruncationForReads, getLargeRowSizeThreshold, getLoadBalanceAutoCommitStatementRegex, getLoadBalanceAutoCommitStatementThreshold, getLoadBalanceBlacklistTimeout, getLoadBalanceConnectionGroup, getLoadBalanceEnableJMX, getLoadBalanceExceptionChecker, getLoadBalanceHostRemovalGracePeriod, getLoadBalancePingTimeout, getLoadBalanceSQLExceptionSubclassFailover, getLoadBalanceSQLStateFailover, getLoadBalanceStrategy, getLoadBalanceValidateConnectionOnSwapServer, getLocalSocketAddress, getLocatorFetchBufferSize, getLogger, getLoggerClassName, getLogSlowQueries, getLogXaCommands, getMaintainTimeStats, getMaxAllowedPacket, getMaxQuerySizeToLog, getMaxReconnects, getMaxRows, getMetadataCacheSize, getNetTimeoutForStreamingResults, getNoAccessToProcedureBodies, getNoDatetimeStringSync, getNoTimezoneConversionForDateType, getNoTimezoneConversionForTimeType, getNullCatalogMeansCurrent, getNullNamePatternMatchesAll, getOverrideSupportsIntegrityEnhancementFacility, getPacketDebugBufferSize, getPadCharsWithSpace, getParanoid, getParseInfoCacheFactory, getPasswordCharacterEncoding, getPedantic, getPinGlobalTxToPhysicalConnection, getPopulateInsertRowWithDefaultValues, getPreparedStatementCacheSize, getPreparedStatementCacheSqlLimit, getPrepStmtCacheSize, getPrepStmtCacheSqlLimit, getProcessEscapeCodesForPrepStmts, getProfilerEventHandler, getProfileSql, getProfileSQL, getPropertiesTransform, getQueriesBeforeRetryMaster, getQueryTimeoutKillsConnection, getReadFromMasterWhenNoSlaves, getReadOnlyPropagatesToServer, getReconnectAtTxEnd, getRelaxAutoCommit, getReplicationConnectionGroup, getReplicationEnableJMX, getReportMetricsIntervalMillis, getRequireSSL, getResourceId, getResultSetSizeThreshold, getRetainStatementAfterResultSetClose, getRetriesAllDown, getRewriteBatchedStatements, getRollbackOnPooledClose, getRoundRobinLoadBalance, getRunningCTS13, getSecondsBeforeRetryMaster, getSelfDestructOnPingMaxOperations, getSelfDestructOnPingSecondsLifetime, getSendFractionalSeconds, getServerAffinityOrder, getServerConfigCacheFactory, getServerRSAPublicKeyFile, getServerTimezone, getSessionVariables, getSlowQueryThresholdMillis, getSlowQueryThresholdNanos, getSocketFactory, getSocketFactoryClassName, getSocketTimeout, getSocksProxyHost, getSocksProxyPort, getStatementInterceptors, getStrictFloatingPoint, getStrictUpdates, getTcpKeepAlive, getTcpNoDelay, getTcpRcvBuf, getTcpSndBuf, getTcpTrafficClass, getTinyInt1isBit, getTraceProtocol, getTransformedBitIsBoolean, getTreatUtilDateAsTimestamp, getTrustCertificateKeyStorePassword, getTrustCertificateKeyStoreType, getTrustCertificateKeyStoreUrl, getUltraDevHack, getUseAffectedRows, getUseBlobToStoreUTF8OutsideBMP, getUseColumnNamesInFindColumn, getUseCompression, getUseConfigs, getUseCursorFetch, getUseDirectRowUnpack, getUseDynamicCharsetInfo, getUseFastDateParsing, getUseFastIntParsing, getUseGmtMillisForDatetimes, getUseHostsInPrivileges, getUseInformationSchema, getUseJDBCCompliantTimezoneShift, getUseJvmCharsetConverters, getUseLegacyDatetimeCode, getUseLocalSessionState, getUseLocalTransactionState, getUseNanosForElapsedTime, getUseOldAliasMetadataBehavior, getUseOldUTF8Behavior, getUseOnlyServerErrorMessages, getUseReadAheadInput, getUseServerPreparedStmts, getUseServerPrepStmts, getUseSqlStateCodes, getUseSSL, getUseSSPSCompatibleTimezoneShift, getUseStreamLengthsInPrepStmts, getUseTimezone, getUseUltraDevWorkAround, getUseUnbufferedInput, getUseUnicode, getUseUsageAdvisor, getUtf8OutsideBmpExcludedColumnNamePattern, getUtf8OutsideBmpIncludedColumnNamePattern, getVerifyServerCertificate, getYearIsDateType, getZeroDateTimeBehavior, initializeFromRef, initializeProperties, isUseSSLExplicit, postInitialization, setAllowLoadLocalInfile, setAllowMasterDownConnections, setAllowMultiQueries, setAllowNanAndInf, setAllowPublicKeyRetrieval, setAllowSlaveDownConnections, setAllowUrlInLocalInfile, setAlwaysSendSetIsolation, setAuthenticationPlugins, setAutoClosePStmtStreams, setAutoDeserialize, setAutoGenerateTestcaseScript, setAutoReconnect, setAutoReconnectForConnectionPools, setAutoReconnectForPools, setAutoSlowLog, setBlobsAreStrings, setBlobSendChunkSize, setCacheCallableStatements, setCacheCallableStmts, setCacheDefaultTimezone, setCachePreparedStatements, setCachePrepStmts, setCacheResultSetMetadata, setCacheServerConfiguration, setCallableStatementCacheSize, setCallableStmtCacheSize, setCapitalizeDBMDTypes, setCapitalizeTypeNames, setCharacterEncoding, setCharacterSetResults, setClientCertificateKeyStorePassword, setClientCertificateKeyStoreType, setClientCertificateKeyStoreUrl, setClientInfoProvider, setClobberStreamingResults, setClobCharacterEncoding, setCompensateOnDuplicateKeyUpdateCounts, setConnectionAttributes, setConnectionCollation, setConnectionLifecycleInterceptors, setConnectTimeout, setContinueBatchOnError, setCreateDatabaseIfNotExist, setDefaultAuthenticationPlugin, setDefaultFetchSize, setDetectCustomCollations, setDetectServerPreparedStmts, setDisabledAuthenticationPlugins, setDisconnectOnExpiredPasswords, setDontCheckOnDuplicateKeyUpdateInSQL, setDontTrackOpenResources, setDumpMetadataOnColumnNotFound, setDumpQueriesOnException, setDynamicCalendars, setElideSetAutoCommits, setEmptyStringsConvertToZero, setEmulateLocators, setEmulateUnsupportedPstmts, setEnabledSSLCipherSuites, setEnabledTLSProtocols, setEnableEscapeProcessing, setEnablePacketDebug, setEnableQueryTimeouts, setEncoding, setExceptionInterceptors, setExplainSlowQueries, setFailOverReadOnly, setFunctionsNeverReturnBlobs, setGatherPerfMetrics, setGatherPerformanceMetrics, setGenerateSimpleParameterMetadata, setGetProceduresReturnsFunctions, setHighAvailability, setHoldResultsOpenOverStatementClose, setIgnoreNonTxTables, setIncludeInnodbStatusInDeadlockExceptions, setIncludeThreadDumpInDeadlockExceptions, setIncludeThreadNamesAsStatementComment, setInitialTimeout, setInteractiveClient, setIsInteractiveClient, setJdbcCompliantTruncation, setJdbcCompliantTruncationForReads, setLargeRowSizeThreshold, setLoadBalanceAutoCommitStatementRegex, setLoadBalanceAutoCommitStatementThreshold, setLoadBalanceBlacklistTimeout, setLoadBalanceConnectionGroup, setLoadBalanceEnableJMX, setLoadBalanceExceptionChecker, setLoadBalanceHostRemovalGracePeriod, setLoadBalancePingTimeout, setLoadBalanceSQLExceptionSubclassFailover, setLoadBalanceSQLStateFailover, setLoadBalanceStrategy, setLoadBalanceValidateConnectionOnSwapServer, setLocalSocketAddress, setLocatorFetchBufferSize, setLogger, setLoggerClassName, setLogSlowQueries, setLogXaCommands, setMaintainTimeStats, setMaxAllowedPacket, setMaxQuerySizeToLog, setMaxReconnects, setMaxRows, setMetadataCacheSize, setNetTimeoutForStreamingResults, setNoAccessToProcedureBodies, setNoDatetimeStringSync, setNoTimezoneConversionForDateType, setNoTimezoneConversionForTimeType, setNullCatalogMeansCurrent, setNullNamePatternMatchesAll, setOverrideSupportsIntegrityEnhancementFacility, setPacketDebugBufferSize, setPadCharsWithSpace, setParanoid, setParseInfoCacheFactory, setPasswordCharacterEncoding, setPedantic, setPinGlobalTxToPhysicalConnection, setPopulateInsertRowWithDefaultValues, setPreparedStatementCacheSize, setPreparedStatementCacheSqlLimit, setPrepStmtCacheSize, setPrepStmtCacheSqlLimit, setProcessEscapeCodesForPrepStmts, setProfilerEventHandler, setProfileSql, setProfileSQL, setPropertiesTransform, setQueriesBeforeRetryMaster, setQueryTimeoutKillsConnection, setReadFromMasterWhenNoSlaves, setReadOnlyPropagatesToServer, setReconnectAtTxEnd, setRelaxAutoCommit, setReplicationConnectionGroup, setReplicationEnableJMX, setReportMetricsIntervalMillis, setRequireSSL, setResourceId, setResultSetSizeThreshold, setRetainStatementAfterResultSetClose, setRetriesAllDown, setRewriteBatchedStatements, setRollbackOnPooledClose, setRoundRobinLoadBalance, setRunningCTS13, setSecondsBeforeRetryMaster, setSelfDestructOnPingMaxOperations, setSelfDestructOnPingSecondsLifetime, setSendFractionalSeconds, setServerAffinityOrder, setServerConfigCacheFactory, setServerRSAPublicKeyFile, setServerTimezone, setSessionVariables, setSlowQueryThresholdMillis, setSlowQueryThresholdNanos, setSocketFactory, setSocketFactoryClassName, setSocketTimeout, setSocksProxyHost, setSocksProxyPort, setStatementInterceptors, setStrictFloatingPoint, setStrictUpdates, setTcpKeepAlive, setTcpNoDelay, setTcpRcvBuf, setTcpSndBuf, setTcpTrafficClass, setTinyInt1isBit, setTraceProtocol, setTransformedBitIsBoolean, setTreatUtilDateAsTimestamp, setTrustCertificateKeyStorePassword, setTrustCertificateKeyStoreType, setTrustCertificateKeyStoreUrl, setUltraDevHack, setUseAffectedRows, setUseBlobToStoreUTF8OutsideBMP, setUseColumnNamesInFindColumn, setUseCompression, setUseConfigs, setUseCursorFetch, setUseDirectRowUnpack, setUseDynamicCharsetInfo, setUseFastDateParsing, setUseFastIntParsing, setUseGmtMillisForDatetimes, setUseHostsInPrivileges, setUseInformationSchema, setUseJDBCCompliantTimezoneShift, setUseJvmCharsetConverters, setUseLegacyDatetimeCode, setUseLocalSessionState, setUseLocalTransactionState, setUseNanosForElapsedTime, setUseOldAliasMetadataBehavior, setUseOldUTF8Behavior, setUseOnlyServerErrorMessages, setUseReadAheadInput, setUseServerPreparedStmts, setUseServerPrepStmts, setUseSqlStateCodes, setUseSSL, setUseSSPSCompatibleTimezoneShift, setUseStreamLengthsInPrepStmts, setUseTimezone, setUseUltraDevWorkAround, setUseUnbufferedInput, setUseUnicode, setUseUsageAdvisor, setUtf8OutsideBmpExcludedColumnNamePattern, setUtf8OutsideBmpIncludedColumnNamePattern, setVerifyServerCertificate, setYearIsDateType, setZeroDateTimeBehavior, storeToRef, useUnbufferedInput

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Connection

beginRequest, createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStruct, endRequest, getClientInfo, getClientInfo, isValid, setClientInfo, setClientInfo, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Methods inherited from interface ConnectionProperties

exposeAsXml, getAllowLoadLocalInfile, getAllowMasterDownConnections, getAllowMultiQueries, getAllowNanAndInf, getAllowPublicKeyRetrieval, getAllowSlaveDownConnections, getAllowUrlInLocalInfile, getAlwaysSendSetIsolation, getAuthenticationPlugins, getAutoClosePStmtStreams, getAutoDeserialize, getAutoGenerateTestcaseScript, getAutoReconnectForPools, getAutoSlowLog, getBlobsAreStrings, getBlobSendChunkSize, getCacheCallableStatements, getCacheCallableStmts, getCacheDefaultTimezone, getCachePreparedStatements, getCachePrepStmts, getCacheResultSetMetadata, getCacheServerConfiguration, getCallableStatementCacheSize, getCallableStmtCacheSize, getCapitalizeTypeNames, getCharacterSetResults, getClientCertificateKeyStorePassword, getClientCertificateKeyStoreType, getClientCertificateKeyStoreUrl, getClientInfoProvider, getClobberStreamingResults, getClobCharacterEncoding, getCompensateOnDuplicateKeyUpdateCounts, getConnectionCollation, getConnectionLifecycleInterceptors, getConnectTimeout, getContinueBatchOnError, getCreateDatabaseIfNotExist, getDefaultAuthenticationPlugin, getDefaultFetchSize, getDetectCustomCollations, getDisabledAuthenticationPlugins, getDisconnectOnExpiredPasswords, getDontCheckOnDuplicateKeyUpdateInSQL, getDontTrackOpenResources, getDumpMetadataOnColumnNotFound, getDumpQueriesOnException, getDynamicCalendars, getElideSetAutoCommits, getEmptyStringsConvertToZero, getEmulateLocators, getEmulateUnsupportedPstmts, getEnabledSSLCipherSuites, getEnabledTLSProtocols, getEnableEscapeProcessing, getEnablePacketDebug, getEnableQueryTimeouts, getEncoding, getExceptionInterceptors, getExplainSlowQueries, getFailOverReadOnly, getFunctionsNeverReturnBlobs, getGatherPerfMetrics, getGatherPerformanceMetrics, getGenerateSimpleParameterMetadata, getGetProceduresReturnsFunctions, getHoldResultsOpenOverStatementClose, getIgnoreNonTxTables, getIncludeInnodbStatusInDeadlockExceptions, getIncludeThreadDumpInDeadlockExceptions, getIncludeThreadNamesAsStatementComment, getInitialTimeout, getInteractiveClient, getIsInteractiveClient, getJdbcCompliantTruncation, getJdbcCompliantTruncationForReads, getLargeRowSizeThreshold, getLoadBalanceAutoCommitStatementRegex, getLoadBalanceAutoCommitStatementThreshold, getLoadBalanceBlacklistTimeout, getLoadBalanceConnectionGroup, getLoadBalanceEnableJMX, getLoadBalanceExceptionChecker, getLoadBalanceHostRemovalGracePeriod, getLoadBalancePingTimeout, getLoadBalanceSQLExceptionSubclassFailover, getLoadBalanceSQLStateFailover, getLoadBalanceStrategy, getLoadBalanceValidateConnectionOnSwapServer, getLocalSocketAddress, getLocatorFetchBufferSize, getLogger, getLoggerClassName, getLogSlowQueries, getLogXaCommands, getMaintainTimeStats, getMaxAllowedPacket, getMaxQuerySizeToLog, getMaxReconnects, getMaxRows, getMetadataCacheSize, getNetTimeoutForStreamingResults, getNoAccessToProcedureBodies, getNoDatetimeStringSync, getNoTimezoneConversionForDateType, getNoTimezoneConversionForTimeType, getNullCatalogMeansCurrent, getNullNamePatternMatchesAll, getOverrideSupportsIntegrityEnhancementFacility, getPacketDebugBufferSize, getPadCharsWithSpace, getParanoid, getParseInfoCacheFactory, getPasswordCharacterEncoding, getPedantic, getPinGlobalTxToPhysicalConnection, getPopulateInsertRowWithDefaultValues, getPreparedStatementCacheSize, getPreparedStatementCacheSqlLimit, getPrepStmtCacheSize, getPrepStmtCacheSqlLimit, getProcessEscapeCodesForPrepStmts, getProfilerEventHandler, getProfileSql, getProfileSQL, getPropertiesTransform, getQueriesBeforeRetryMaster, getQueryTimeoutKillsConnection, getReadFromMasterWhenNoSlaves, getReadOnlyPropagatesToServer, getReconnectAtTxEnd, getRelaxAutoCommit, getReplicationEnableJMX, getReportMetricsIntervalMillis, getRequireSSL, getResourceId, getResultSetSizeThreshold, getRetainStatementAfterResultSetClose, getRetriesAllDown, getRewriteBatchedStatements, getRollbackOnPooledClose, getRoundRobinLoadBalance, getRunningCTS13, getSecondsBeforeRetryMaster, getSelfDestructOnPingMaxOperations, getSelfDestructOnPingSecondsLifetime, getSendFractionalSeconds, getServerAffinityOrder, getServerConfigCacheFactory, getServerRSAPublicKeyFile, getServerTimezone, getSessionVariables, getSlowQueryThresholdMillis, getSlowQueryThresholdNanos, getSocketFactory, getSocketFactoryClassName, getSocketTimeout, getSocksProxyHost, getSocksProxyPort, getStatementInterceptors, getStrictFloatingPoint, getStrictUpdates, getTcpKeepAlive, getTcpNoDelay, getTcpRcvBuf, getTcpSndBuf, getTcpTrafficClass, getTinyInt1isBit, getTraceProtocol, getTransformedBitIsBoolean, getTreatUtilDateAsTimestamp, getTrustCertificateKeyStorePassword, getTrustCertificateKeyStoreType, getTrustCertificateKeyStoreUrl, getUltraDevHack, getUseAffectedRows, getUseBlobToStoreUTF8OutsideBMP, getUseColumnNamesInFindColumn, getUseCompression, getUseConfigs, getUseCursorFetch, getUseDirectRowUnpack, getUseDynamicCharsetInfo, getUseFastDateParsing, getUseFastIntParsing, getUseGmtMillisForDatetimes, getUseHostsInPrivileges, getUseInformationSchema, getUseJDBCCompliantTimezoneShift, getUseJvmCharsetConverters, getUseLegacyDatetimeCode, getUseLocalSessionState, getUseLocalTransactionState, getUseNanosForElapsedTime, getUseOldAliasMetadataBehavior, getUseOldUTF8Behavior, getUseOnlyServerErrorMessages, getUseReadAheadInput, getUseServerPreparedStmts, getUseServerPrepStmts, getUseSqlStateCodes, getUseSSL, getUseSSPSCompatibleTimezoneShift, getUseStreamLengthsInPrepStmts, getUseTimezone, getUseUltraDevWorkAround, getUseUnbufferedInput, getUseUnicode, getUseUsageAdvisor, getUtf8OutsideBmpExcludedColumnNamePattern, getUtf8OutsideBmpIncludedColumnNamePattern, getVerifyServerCertificate, getYearIsDateType, getZeroDateTimeBehavior, isUseSSLExplicit, setAllowLoadLocalInfile, setAllowMasterDownConnections, setAllowMultiQueries, setAllowNanAndInf, setAllowPublicKeyRetrieval, setAllowSlaveDownConnections, setAllowUrlInLocalInfile, setAlwaysSendSetIsolation, setAuthenticationPlugins, setAutoClosePStmtStreams, setAutoDeserialize, setAutoGenerateTestcaseScript, setAutoReconnect, setAutoReconnectForConnectionPools, setAutoReconnectForPools, setAutoSlowLog, setBlobsAreStrings, setBlobSendChunkSize, setCacheCallableStatements, setCacheCallableStmts, setCacheDefaultTimezone, setCachePreparedStatements, setCachePrepStmts, setCacheResultSetMetadata, setCacheServerConfiguration, setCallableStatementCacheSize, setCallableStmtCacheSize, setCapitalizeDBMDTypes, setCapitalizeTypeNames, setCharacterEncoding, setCharacterSetResults, setClientCertificateKeyStorePassword, setClientCertificateKeyStoreType, setClientCertificateKeyStoreUrl, setClientInfoProvider, setClobberStreamingResults, setClobCharacterEncoding, setCompensateOnDuplicateKeyUpdateCounts, setConnectionCollation, setConnectionLifecycleInterceptors, setConnectTimeout, setContinueBatchOnError, setCreateDatabaseIfNotExist, setDefaultAuthenticationPlugin, setDefaultFetchSize, setDetectCustomCollations, setDetectServerPreparedStmts, setDisabledAuthenticationPlugins, setDisconnectOnExpiredPasswords, setDontCheckOnDuplicateKeyUpdateInSQL, setDontTrackOpenResources, setDumpMetadataOnColumnNotFound, setDumpQueriesOnException, setDynamicCalendars, setElideSetAutoCommits, setEmptyStringsConvertToZero, setEmulateLocators, setEmulateUnsupportedPstmts, setEnabledSSLCipherSuites, setEnabledTLSProtocols, setEnableEscapeProcessing, setEnablePacketDebug, setEnableQueryTimeouts, setEncoding, setExceptionInterceptors, setExplainSlowQueries, setFailOverReadOnly, setFunctionsNeverReturnBlobs, setGatherPerfMetrics, setGatherPerformanceMetrics, setGenerateSimpleParameterMetadata, setGetProceduresReturnsFunctions, setHoldResultsOpenOverStatementClose, setIgnoreNonTxTables, setIncludeInnodbStatusInDeadlockExceptions, setIncludeThreadDumpInDeadlockExceptions, setIncludeThreadNamesAsStatementComment, setInitialTimeout, setInteractiveClient, setIsInteractiveClient, setJdbcCompliantTruncation, setJdbcCompliantTruncationForReads, setLargeRowSizeThreshold, setLoadBalanceAutoCommitStatementRegex, setLoadBalanceAutoCommitStatementThreshold, setLoadBalanceBlacklistTimeout, setLoadBalanceConnectionGroup, setLoadBalanceEnableJMX, setLoadBalanceExceptionChecker, setLoadBalanceHostRemovalGracePeriod, setLoadBalancePingTimeout, setLoadBalanceSQLExceptionSubclassFailover, setLoadBalanceSQLStateFailover, setLoadBalanceStrategy, setLoadBalanceValidateConnectionOnSwapServer, setLocalSocketAddress, setLocatorFetchBufferSize, setLogger, setLoggerClassName, setLogSlowQueries, setLogXaCommands, setMaintainTimeStats, setMaxQuerySizeToLog, setMaxReconnects, setMaxRows, setMetadataCacheSize, setNetTimeoutForStreamingResults, setNoAccessToProcedureBodies, setNoDatetimeStringSync, setNoTimezoneConversionForDateType, setNoTimezoneConversionForTimeType, setNullCatalogMeansCurrent, setNullNamePatternMatchesAll, setOverrideSupportsIntegrityEnhancementFacility, setPacketDebugBufferSize, setPadCharsWithSpace, setParanoid, setParseInfoCacheFactory, setPasswordCharacterEncoding, setPedantic, setPinGlobalTxToPhysicalConnection, setPopulateInsertRowWithDefaultValues, setPreparedStatementCacheSize, setPreparedStatementCacheSqlLimit, setPrepStmtCacheSize, setPrepStmtCacheSqlLimit, setProcessEscapeCodesForPrepStmts, setProfilerEventHandler, setProfileSql, setProfileSQL, setPropertiesTransform, setQueriesBeforeRetryMaster, setQueryTimeoutKillsConnection, setReadFromMasterWhenNoSlaves, setReadOnlyPropagatesToServer, setReconnectAtTxEnd, setRelaxAutoCommit, setReplicationEnableJMX, setReportMetricsIntervalMillis, setRequireSSL, setResourceId, setResultSetSizeThreshold, setRetainStatementAfterResultSetClose, setRetriesAllDown, setRewriteBatchedStatements, setRollbackOnPooledClose, setRoundRobinLoadBalance, setRunningCTS13, setSecondsBeforeRetryMaster, setSelfDestructOnPingMaxOperations, setSelfDestructOnPingSecondsLifetime, setSendFractionalSeconds, setServerAffinityOrder, setServerConfigCacheFactory, setServerRSAPublicKeyFile, setServerTimezone, setSessionVariables, setSlowQueryThresholdMillis, setSlowQueryThresholdNanos, setSocketFactory, setSocketFactoryClassName, setSocketTimeout, setSocksProxyHost, setSocksProxyPort, setStatementInterceptors, setStrictFloatingPoint, setStrictUpdates, setTcpKeepAlive, setTcpNoDelay, setTcpRcvBuf, setTcpSndBuf, setTcpTrafficClass, setTinyInt1isBit, setTraceProtocol, setTransformedBitIsBoolean, setTreatUtilDateAsTimestamp, setTrustCertificateKeyStorePassword, setTrustCertificateKeyStoreType, setTrustCertificateKeyStoreUrl, setUltraDevHack, setUseAffectedRows, setUseBlobToStoreUTF8OutsideBMP, setUseColumnNamesInFindColumn, setUseCompression, setUseConfigs, setUseCursorFetch, setUseDirectRowUnpack, setUseDynamicCharsetInfo, setUseFastDateParsing, setUseFastIntParsing, setUseGmtMillisForDatetimes, setUseHostsInPrivileges, setUseInformationSchema, setUseJDBCCompliantTimezoneShift, setUseJvmCharsetConverters, setUseLegacyDatetimeCode, setUseLocalSessionState, setUseLocalTransactionState, setUseNanosForElapsedTime, setUseOldAliasMetadataBehavior, setUseOldUTF8Behavior, setUseOnlyServerErrorMessages, setUseReadAheadInput, setUseServerPreparedStmts, setUseServerPrepStmts, setUseSqlStateCodes, setUseSSL, setUseSSPSCompatibleTimezoneShift, setUseStreamLengthsInPrepStmts, setUseTimezone, setUseUltraDevWorkAround, setUseUnbufferedInput, setUseUnicode, setUseUsageAdvisor, setUtf8OutsideBmpExcludedColumnNamePattern, setUtf8OutsideBmpIncludedColumnNamePattern, setVerifyServerCertificate, setYearIsDateType, setZeroDateTimeBehavior, useUnbufferedInput

Methods inherited from interface MySQLConnection

getConnectionAttributes

Methods inherited from interface Wrapper

isWrapperFor, unwrap

Field Details

JDBC_LOCAL_CHARACTER_SET_RESULTS

public static final String JDBC_LOCAL_CHARACTER_SET_RESULTS

See Also:

• Constant Field Values

charsetMap

public static Map<?,?> charsetMap

The mapping between MySQL charset names and Java charset names. Initialized by loadCharacterSetMapping()

DEFAULT_LOGGER_CLASS

protected static final String DEFAULT_LOGGER_CLASS

Default logger class name

See Also:

• Constant Field Values

roundRobinStatsMap

protected static Map<?,?> roundRobinStatsMap

indexToCustomMysqlCharset

public Map<Integer,String> indexToCustomMysqlCharset

props

protected Properties props

Properties for this connection specified by user

resultSetMetadataCache

protected com.mysql.jdbc.util.LRUCache<String, CachedResultSetMetaData> resultSetMetadataCache

Cache of ResultSet metadata

Constructor Details

ConnectionImpl

protected ConnectionImpl()

' For the delegate only

ConnectionImpl

public ConnectionImpl(String hostToConnectTo,
 int portToConnectTo,
 Properties info,
 String databaseToConnectTo,
 String url)
               throws SQLException

Creates a connection to a MySQL Server.

Parameters:

hostToConnectTo - the hostname of the database server

portToConnectTo - the port number the server is listening on

info - a Properties[] list holding the user and password

databaseToConnectTo - the database to connect to

url - the URL of the connection

d - the Driver instantation of the connection

Throws:

SQLException - if a database access error occurs

Method Details

getHost

public String getHost()

Specified by:

getHost in interface Connection

Specified by:

getHost in interface MySQLConnection

getHostPortPair

public String getHostPortPair()

Specified by:

getHostPortPair in interface MySQLConnection

isProxySet

public boolean isProxySet()

Specified by:

isProxySet in interface MySQLConnection

setProxy

public void setProxy(MySQLConnection proxy)

Specified by:

setProxy in interface Connection

Specified by:

setProxy in interface MySQLConnection

getLoadBalanceSafeProxy

@Deprecated
public MySQLConnection getLoadBalanceSafeProxy()

Deprecated.

replaced by getMultiHostSafeProxy()

Specified by:

getLoadBalanceSafeProxy in interface MySQLConnection

getMultiHostSafeProxy

public MySQLConnection getMultiHostSafeProxy()

Specified by:

getMultiHostSafeProxy in interface MySQLConnection

getActiveMySQLConnection

public MySQLConnection getActiveMySQLConnection()

Specified by:

getActiveMySQLConnection in interface MySQLConnection

getConnectionMutex

public Object getConnectionMutex()

Specified by:

getConnectionMutex in interface Connection

appendMessageToException

protected static SQLException appendMessageToException(SQLException sqlEx,
 String messageToAppend,
 ExceptionInterceptor interceptor)

getCancelTimer

public Timer getCancelTimer()

Specified by:

getCancelTimer in interface MySQLConnection

getInstance

protected static Connection getInstance(String hostToConnectTo,
 int portToConnectTo,
 Properties info,
 String databaseToConnectTo,
 String url)
                                 throws SQLException

Creates a connection instance -- We need to provide factory-style methods so we can support both JDBC3 (and older) and JDBC4 runtimes, otherwise the class verifier complains when it tries to load JDBC4-only interface classes that are present in JDBC4 method signatures.

Throws:

SQLException

getNextRoundRobinHostIndex

protected static int getNextRoundRobinHostIndex(String url,
 List<?> hostList)

Parameters:

url -

hostList -

unSafeStatementInterceptors

public void unSafeStatementInterceptors()
                                 throws SQLException

Specified by:

unSafeStatementInterceptors in interface MySQLConnection

Throws:

SQLException

initializeSafeStatementInterceptors

public void initializeSafeStatementInterceptors()
                                         throws SQLException

Specified by:

initializeSafeStatementInterceptors in interface MySQLConnection

Throws:

SQLException

getStatementInterceptorsInstances

public List<StatementInterceptorV2> getStatementInterceptorsInstances()

Specified by:

getStatementInterceptorsInstances in interface MySQLConnection

changeUser

public void changeUser(String userName,
 String newPassword)
                throws SQLException

Changes the user on this connection by performing a re-authentication. If authentication fails, the connection will remain under the context of the current user.

Specified by:

changeUser in interface Connection

Parameters:

userName - the username to authenticate with

newPassword - the password to authenticate with

Throws:

SQLException - if authentication fails, or some other error occurs while performing the command.

checkClosed

public void checkClosed()
                 throws SQLException

Specified by:

checkClosed in interface Connection

Throws:

SQLException

throwConnectionClosedException

public void throwConnectionClosedException()
                                    throws SQLException

Specified by:

throwConnectionClosedException in interface MySQLConnection

Throws:

SQLException

abortInternal

public void abortInternal()
                   throws SQLException

Clobbers the physical network connection and marks this connection as closed.

Specified by:

abortInternal in interface Connection

Throws:

SQLException

clearHasTriedMaster

@Deprecated
public void clearHasTriedMaster()

Deprecated.

Specified by:

clearHasTriedMaster in interface Connection

clearWarnings

public void clearWarnings()
                   throws SQLException

After this call, getWarnings returns null until a new warning is reported for this connection.

Specified by:

clearWarnings in interface Connection

Throws:

SQLException - if a database access error occurs

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

clientPrepareStatement in interface Connection

Parameters:

sql -

Throws:

SQLException

See Also:

• Connection.prepareStatement(String)

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql,
 int autoGenKeyIndex)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

clientPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int)

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

clientPrepareStatement in interface Connection

Parameters:

sql -

resultSetType -

resultSetConcurrency -

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int, int)

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency,
 boolean processEscapeCodesIfNeeded)
                                         throws SQLException

Throws:

SQLException

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql,
 int[] autoGenKeyIndexes)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

clientPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int[])

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql,
 String[] autoGenKeyColNames)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

clientPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, String[])

clientPrepareStatement

public PreparedStatement clientPrepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the client, using client-side emulation (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

clientPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int, int, int)

close

public void close()
           throws SQLException

In some cases, it is desirable to immediately release a Connection's database and JDBC resources instead of waiting for them to be automatically released (cant think why off the top of my head) Note: A Connection is automatically closed when it is garbage collected. Certain fatal errors also result in a closed connection.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Connection

Throws:

SQLException - if a database access error occurs

commit

public void commit()
            throws SQLException

The method commit() makes all changes made since the previous commit/rollback permanent and releases any database locks currently held by the Connection. This method should only be used when auto-commit has been disabled.

Note: MySQL does not support transactions, so this method is a no-op.

Specified by:

commit in interface Connection

Throws:

SQLException - if a database access error occurs

See Also:

• setAutoCommit(boolean)

createNewIO

public void createNewIO(boolean isForReconnect)
                 throws SQLException

Creates an IO channel to the server

Specified by:

createNewIO in interface MySQLConnection

Parameters:

isForReconnect - is this request for a re-connect

Throws:

SQLException - if a database access error occurs

CommunicationsException

createStatement

public Statement createStatement()
                          throws SQLException

SQL statements without parameters are normally executed using Statement objects. If the same SQL statement is executed many times, it is more efficient to use a PreparedStatement

Specified by:

createStatement in interface Connection

Returns:

a new Statement object

Throws:

SQLException - passed through from the constructor

createStatement

public Statement createStatement(int resultSetType,
 int resultSetConcurrency)
                          throws SQLException

JDBC 2.0 Same as createStatement() above, but allows the default result set type and result set concurrency type to be overridden.

Specified by:

createStatement in interface Connection

Parameters:

resultSetType - a result set type, see ResultSet.TYPE_XXX

resultSetConcurrency - a concurrency type, see ResultSet.CONCUR_XXX

Returns:

a new Statement object

Throws:

SQLException - if a database-access error occurs.

createStatement

public Statement createStatement(int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                          throws SQLException

Specified by:

createStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.createStatement(int, int, int)

dumpTestcaseQuery

public void dumpTestcaseQuery(String query)

Specified by:

dumpTestcaseQuery in interface MySQLConnection

duplicate

public Connection duplicate()
                     throws SQLException

Specified by:

duplicate in interface MySQLConnection

Throws:

SQLException

execSQL

public ResultSetInternalMethods execSQL(StatementImpl callingStatement,
 String sql,
 int maxRows,
 Buffer packet,
 int resultSetType,
 int resultSetConcurrency,
 boolean streamResults,
 String catalog,
 Field[] cachedMetadata)
                                 throws SQLException

Send a query to the server. Returns one of the ResultSet objects. This is synchronized, so Statement's queries will be serialized.

Specified by:

execSQL in interface MySQLConnection

Parameters:

callingStatement -

sql - the SQL statement to be executed

maxRows -

packet -

resultSetType -

resultSetConcurrency -

streamResults -

catalog -

queryIsSelectOnly -

unpackFields -

Returns:

a ResultSet holding the results

Throws:

SQLException - if a database error occurs

execSQL

public ResultSetInternalMethods execSQL(StatementImpl callingStatement,
 String sql,
 int maxRows,
 Buffer packet,
 int resultSetType,
 int resultSetConcurrency,
 boolean streamResults,
 String catalog,
 Field[] cachedMetadata,
 boolean isBatch)
                                 throws SQLException

Specified by:

execSQL in interface MySQLConnection

Throws:

SQLException

extractSqlFromPacket

public String extractSqlFromPacket(String possibleSqlQuery,
 Buffer queryPacket,
 int endOfQueryPacketPosition)
                            throws SQLException

Specified by:

extractSqlFromPacket in interface MySQLConnection

Throws:

SQLException

generateConnectionCommentBlock

public StringBuilder generateConnectionCommentBlock(StringBuilder buf)

Specified by:

generateConnectionCommentBlock in interface MySQLConnection

getActiveStatementCount

public int getActiveStatementCount()

Description copied from interface: Connection

Returns the number of statements active on this connection, which haven't been .close()d.

Specified by:

getActiveStatementCount in interface Connection

Specified by:

getActiveStatementCount in interface MySQLConnection

getAutoCommit

public boolean getAutoCommit()
                      throws SQLException

Gets the current auto-commit state

Specified by:

getAutoCommit in interface Connection

Returns:

Current state of auto-commit

Throws:

SQLException - if an error occurs

See Also:

• setAutoCommit(boolean)

getCalendarInstanceForSessionOrNew

public Calendar getCalendarInstanceForSessionOrNew()

Optimization to only use one calendar per-session, or calculate it for each call, depending on user configuration

Specified by:

getCalendarInstanceForSessionOrNew in interface MySQLConnection

getCatalog

public String getCatalog()
                  throws SQLException

Return the connections current catalog name, or null if no catalog name is set, or we dont support catalogs.

Note: MySQL's notion of catalogs are individual databases.

Specified by:

getCatalog in interface Connection

Returns:

the current catalog name or null

Throws:

SQLException - if a database access error occurs

getCharacterSetMetadata

public String getCharacterSetMetadata()

Specified by:

getCharacterSetMetadata in interface MySQLConnection

Returns:

Returns the characterSetMetadata.

getCharsetConverter

public SingleByteCharsetConverter getCharsetConverter(String javaEncodingName)
                                               throws SQLException

Returns the locally mapped instance of a charset converter (to avoid overhead of static synchronization).

Specified by:

getCharsetConverter in interface MySQLConnection

Parameters:

javaEncodingName - the encoding name to retrieve

Returns:

a character converter, or null if one couldn't be mapped.

Throws:

SQLException

getCharsetNameForIndex

@Deprecated
public String getCharsetNameForIndex(int charsetIndex)
                              throws SQLException

Deprecated.

replaced by getEncodingForIndex(int charsetIndex)

Specified by:

getCharsetNameForIndex in interface MySQLConnection

Throws:

SQLException

getEncodingForIndex

public String getEncodingForIndex(int charsetIndex)
                           throws SQLException

Returns the Java character encoding name for the given MySQL server charset index

Specified by:

getEncodingForIndex in interface MySQLConnection

Parameters:

charsetIndex -

Returns:

the Java character encoding name for the given MySQL server charset index

Throws:

SQLException - if the character set index isn't known by the driver

getDefaultTimeZone

public TimeZone getDefaultTimeZone()

Specified by:

getDefaultTimeZone in interface MySQLConnection

Returns:

Returns the defaultTimeZone.

getErrorMessageEncoding

public String getErrorMessageEncoding()

Specified by:

getErrorMessageEncoding in interface MySQLConnection

getHoldability

public int getHoldability()
                   throws SQLException

Specified by:

getHoldability in interface Connection

Throws:

SQLException

See Also:

• Connection.getHoldability()

getId

public long getId()

Specified by:

getId in interface MySQLConnection

getIdleFor

public long getIdleFor()

NOT JDBC-Compliant, but clients can use this method to determine how long this connection has been idle. This time (reported in milliseconds) is updated once a query has completed.

Specified by:

getIdleFor in interface Connection

Specified by:

getIdleFor in interface MySQLConnection

Returns:

number of ms that this connection has been idle, 0 if the driver is busy retrieving results.

getIO

public MysqlIO getIO()
              throws SQLException

Returns the IO channel to the server

Specified by:

getIO in interface MySQLConnection

Returns:

the IO channel to the server

Throws:

SQLException - if the connection is closed.

getLog

public com.mysql.jdbc.log.Log getLog()
                              throws SQLException

Returns the log mechanism that should be used to log information from/for this Connection.

Specified by:

getLog in interface Connection

Specified by:

getLog in interface MySQLConnection

Returns:

the Log instance to use for logging messages.

Throws:

SQLException - if an error occurs

getMaxBytesPerChar

public int getMaxBytesPerChar(String javaCharsetName)
                       throws SQLException

Specified by:

getMaxBytesPerChar in interface MySQLConnection

Throws:

SQLException

getMaxBytesPerChar

public int getMaxBytesPerChar(Integer charsetIndex,
 String javaCharsetName)
                       throws SQLException

Specified by:

getMaxBytesPerChar in interface MySQLConnection

Throws:

SQLException

getMetaData

public DatabaseMetaData getMetaData()
                             throws SQLException

A connection's database is able to provide information describing its tables, its supported SQL grammar, its stored procedures, the capabilities of this connection, etc. This information is made available through a DatabaseMetaData object.

Specified by:

getMetaData in interface Connection

Returns:

a DatabaseMetaData object for this connection

Throws:

SQLException - if a database access error occurs

getMetadataSafeStatement

public Statement getMetadataSafeStatement()
                                   throws SQLException

Specified by:

getMetadataSafeStatement in interface MySQLConnection

Throws:

SQLException

getMetadataSafeStatement

public Statement getMetadataSafeStatement(int maxRows)
                                   throws SQLException

Throws:

SQLException

getNetBufferLength

public int getNetBufferLength()

Returns the packet buffer size the MySQL server reported upon connection

Specified by:

getNetBufferLength in interface MySQLConnection

getServerCharacterEncoding

@Deprecated
public String getServerCharacterEncoding()

Deprecated.

replaced by getServerCharset()

Description copied from interface: Connection

Returns the server's character set

Specified by:

getServerCharacterEncoding in interface Connection

Returns:

the server's character set.

getServerCharset

public String getServerCharset()

Returns the server's character set

Specified by:

getServerCharset in interface Connection

Specified by:

getServerCharset in interface MySQLConnection

Returns:

the server's character set.

getServerMajorVersion

public int getServerMajorVersion()

Specified by:

getServerMajorVersion in interface MySQLConnection

getServerMinorVersion

public int getServerMinorVersion()

Specified by:

getServerMinorVersion in interface MySQLConnection

getServerSubMinorVersion

public int getServerSubMinorVersion()

Specified by:

getServerSubMinorVersion in interface MySQLConnection

getServerTimezoneTZ

public TimeZone getServerTimezoneTZ()

Description copied from interface: Connection

Returns the TimeZone that represents the configured timezone for the server.

Specified by:

getServerTimezoneTZ in interface Connection

Specified by:

getServerTimezoneTZ in interface MySQLConnection

getServerVariable

public String getServerVariable(String variableName)

Specified by:

getServerVariable in interface MySQLConnection

getServerVersion

public String getServerVersion()

Specified by:

getServerVersion in interface MySQLConnection

getSessionLockedCalendar

public Calendar getSessionLockedCalendar()

Specified by:

getSessionLockedCalendar in interface MySQLConnection

getTransactionIsolation

public int getTransactionIsolation()
                            throws SQLException

Get this Connection's current transaction isolation mode.

Specified by:

getTransactionIsolation in interface Connection

Returns:

the current TRANSACTION_ mode value

Throws:

SQLException - if a database access error occurs

getTypeMap

public Map<String,Class<?>> getTypeMap()
                                throws SQLException

JDBC 2.0 Get the type-map object associated with this connection. By default, the map returned is empty.

Specified by:

getTypeMap in interface Connection

Returns:

the type map

Throws:

SQLException - if a database error occurs

getURL

public String getURL()

Specified by:

getURL in interface MySQLConnection

getUser

public String getUser()

Specified by:

getUser in interface MySQLConnection

getUtcCalendar

public Calendar getUtcCalendar()

Specified by:

getUtcCalendar in interface MySQLConnection

getWarnings

public SQLWarning getWarnings()
                       throws SQLException

The first warning reported by calls on this Connection is returned. Note: Sebsequent warnings will be changed to this java.sql.SQLWarning

Specified by:

getWarnings in interface Connection

Returns:

the first java.sql.SQLWarning or null

Throws:

SQLException - if a database access error occurs

hasSameProperties

public boolean hasSameProperties(Connection c)

Description copied from interface: Connection

Does this connection have the same properties as another?

Specified by:

hasSameProperties in interface Connection

getProperties

public Properties getProperties()

Description copied from interface: Connection

Returns the parsed and passed in properties for this connection.

Specified by:

getProperties in interface Connection

Specified by:

getProperties in interface MySQLConnection

hasTriedMaster

@Deprecated
public boolean hasTriedMaster()

Deprecated.

Description copied from interface: Connection

Has this connection tried to execute a query on the "master" server (first host in a multiple host list).

Specified by:

hasTriedMaster in interface Connection

incrementNumberOfPreparedExecutes

public void incrementNumberOfPreparedExecutes()

Specified by:

incrementNumberOfPreparedExecutes in interface MySQLConnection

incrementNumberOfPrepares

public void incrementNumberOfPrepares()

Specified by:

incrementNumberOfPrepares in interface MySQLConnection

incrementNumberOfResultSetsCreated

public void incrementNumberOfResultSetsCreated()

Specified by:

incrementNumberOfResultSetsCreated in interface MySQLConnection

isQueryCacheEnabled

public boolean isQueryCacheEnabled()

isClientTzUTC

public boolean isClientTzUTC()

Specified by:

isClientTzUTC in interface MySQLConnection

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Connection

isCursorFetchEnabled

public boolean isCursorFetchEnabled()
                             throws SQLException

Specified by:

isCursorFetchEnabled in interface MySQLConnection

Throws:

SQLException

isInGlobalTx

public boolean isInGlobalTx()

Description copied from interface: Connection

Is this connection currently a participant in an XA transaction?

Specified by:

isInGlobalTx in interface Connection

isMasterConnection

public boolean isMasterConnection()

Is this connection connected to the first host in the list if there is a list of servers in the URL?

Specified by:

isMasterConnection in interface Connection

Returns:

true if this connection is connected to the first in the list.

isNoBackslashEscapesSet

public boolean isNoBackslashEscapesSet()

Is the server in a sql_mode that doesn't allow us to use \\ to escape things?

Specified by:

isNoBackslashEscapesSet in interface Connection

Returns:

Returns the noBackslashEscapes.

isReadInfoMsgEnabled

public boolean isReadInfoMsgEnabled()

Specified by:

isReadInfoMsgEnabled in interface MySQLConnection

isReadOnly

public boolean isReadOnly()
                   throws SQLException

Tests to see if the connection is in Read Only Mode. Note that prior to 5.6, we cannot really put the database in read only mode, but we pretend we can by returning the value of the readOnly flag

Specified by:

isReadOnly in interface Connection

Specified by:

isReadOnly in interface MySQLConnection

Returns:

true if the connection is read only

Throws:

SQLException - if a database access error occurs

isReadOnly

public boolean isReadOnly(boolean useSessionStatus)
                   throws SQLException

Tests to see if the connection is in Read Only Mode. Note that prior to 5.6, we cannot really put the database in read only mode, but we pretend we can by returning the value of the readOnly flag

Specified by:

isReadOnly in interface MySQLConnection

Parameters:

useSessionStatus - in some cases, for example when restoring connection with autoReconnect=true, we can rely only on saved readOnly state, so use useSessionStatus=false in that case

Returns:

true if the connection is read only

Throws:

SQLException - if a database access error occurs

isRunningOnJDK13

public boolean isRunningOnJDK13()

Specified by:

isRunningOnJDK13 in interface MySQLConnection

isSameResource

public boolean isSameResource(Connection otherConnection)

Description copied from interface: Connection

Does this connection have the same resource name as the given connection (for XA)?

Specified by:

isSameResource in interface Connection

Parameters:

otherConnection -

isServerTzUTC

public boolean isServerTzUTC()

Specified by:

isServerTzUTC in interface MySQLConnection

getAutoIncrementIncrement

public int getAutoIncrementIncrement()

Description copied from interface: Connection

Returns the -session- value of 'auto_increment_increment' from the server if it exists, or '1' if not.

Specified by:

getAutoIncrementIncrement in interface Connection

Specified by:

getAutoIncrementIncrement in interface MySQLConnection

lowerCaseTableNames

public boolean lowerCaseTableNames()

Is the server configured to use lower-case table names only?

Specified by:

lowerCaseTableNames in interface Connection

Specified by:

lowerCaseTableNames in interface MySQLConnection

Returns:

true if lower_case_table_names is 'on'

nativeSQL

public String nativeSQL(String sql)
                 throws SQLException

A driver may convert the JDBC sql grammar into its system's native SQL grammar prior to sending it; nativeSQL returns the native form of the statement that the driver would have sent.

Specified by:

nativeSQL in interface Connection

Parameters:

sql - a SQL statement that may contain one or more '?' parameter placeholders

Returns:

the native form of this statement

Throws:

SQLException - if a database access error occurs

parserKnowsUnicode

public boolean parserKnowsUnicode()

Description copied from interface: Connection

Does the server this connection is connected to support unicode?

Specified by:

parserKnowsUnicode in interface Connection

ping

public void ping()
          throws SQLException

Detect if the connection is still good

Specified by:

ping in interface Connection

Throws:

SQLException - if the ping fails

pingInternal

public void pingInternal(boolean checkForClosedConnection,
 int timeoutMillis)
                  throws SQLException

Specified by:

pingInternal in interface MySQLConnection

Throws:

SQLException

prepareCall

public CallableStatement prepareCall(String sql)
                              throws SQLException

Specified by:

prepareCall in interface Connection

Parameters:

sql -

Throws:

SQLException

prepareCall

public CallableStatement prepareCall(String sql,
 int resultSetType,
 int resultSetConcurrency)
                              throws SQLException

JDBC 2.0 Same as prepareCall() above, but allows the default result set type and result set concurrency type to be overridden.

Specified by:

prepareCall in interface Connection

Parameters:

sql - the SQL representing the callable statement

resultSetType - a result set type, see ResultSet.TYPE_XXX

resultSetConcurrency - a concurrency type, see ResultSet.CONCUR_XXX

Returns:

a new CallableStatement object containing the pre-compiled SQL statement

Throws:

SQLException - if a database-access error occurs.

prepareCall

public CallableStatement prepareCall(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                              throws SQLException

Specified by:

prepareCall in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareCall(String, int, int, int)

prepareStatement

public PreparedStatement prepareStatement(String sql)
                                   throws SQLException

A SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object. This object can then be used to efficiently execute this statement multiple times.

Note: This method is optimized for handling parametric SQL statements that benefit from precompilation if the driver supports precompilation. In this case, the statement is not sent to the database until the PreparedStatement is executed. This has no direct effect on users; however it does affect which method throws certain java.sql.SQLExceptions

MySQL does not support precompilation of statements, so they are handled by the driver.

Specified by:

prepareStatement in interface Connection

Parameters:

sql - a SQL statement that may contain one or more '?' IN parameter placeholders

Returns:

a new PreparedStatement object containing the pre-compiled statement.

Throws:

SQLException - if a database access error occurs.

prepareStatement

public PreparedStatement prepareStatement(String sql,
 int autoGenKeyIndex)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int)

prepareStatement

public PreparedStatement prepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency)
                                   throws SQLException

JDBC 2.0 Same as prepareStatement() above, but allows the default result set type and result set concurrency type to be overridden.

Specified by:

prepareStatement in interface Connection

Parameters:

sql - the SQL query containing place holders

resultSetType - a result set type, see ResultSet.TYPE_XXX

resultSetConcurrency - a concurrency type, see ResultSet.CONCUR_XXX

Returns:

a new PreparedStatement object containing the pre-compiled SQL statement

Throws:

SQLException - if a database-access error occurs.

prepareStatement

public PreparedStatement prepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int, int, int)

prepareStatement

public PreparedStatement prepareStatement(String sql,
 int[] autoGenKeyIndexes)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int[])

prepareStatement

public PreparedStatement prepareStatement(String sql,
 String[] autoGenKeyColNames)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, String[])

realClose

public void realClose(boolean calledExplicitly,
 boolean issueRollback,
 boolean skipLocalTeardown,
 Throwable reason)
               throws SQLException

Closes connection and frees resources.

Specified by:

realClose in interface MySQLConnection

Parameters:

calledExplicitly - is this being called from close()

issueRollback - should a rollback() be issued?

Throws:

SQLException - if an error occurs

recachePreparedStatement

public void recachePreparedStatement(ServerPreparedStatement pstmt)
                              throws SQLException

Specified by:

recachePreparedStatement in interface MySQLConnection

Throws:

SQLException

decachePreparedStatement

public void decachePreparedStatement(ServerPreparedStatement pstmt)
                              throws SQLException

Specified by:

decachePreparedStatement in interface MySQLConnection

Throws:

SQLException

registerQueryExecutionTime

public void registerQueryExecutionTime(long queryTimeMs)

Specified by:

registerQueryExecutionTime in interface MySQLConnection

Parameters:

queryTimeMs -

registerStatement

public void registerStatement(Statement stmt)

Register a Statement instance as open.

Specified by:

registerStatement in interface MySQLConnection

Parameters:

stmt - the Statement instance to remove

releaseSavepoint

public void releaseSavepoint(Savepoint arg0)
                      throws SQLException

Specified by:

releaseSavepoint in interface Connection

Throws:

SQLException

See Also:

• Connection.releaseSavepoint(Savepoint)

reportMetricsIfNeeded

protected void reportMetricsIfNeeded()

Reports currently collected metrics if this feature is enabled and the timeout has passed.

reportNumberOfTablesAccessed

public void reportNumberOfTablesAccessed(int numTablesAccessed)

Specified by:

reportNumberOfTablesAccessed in interface MySQLConnection

resetServerState

public void resetServerState()
                      throws SQLException

Resets the server-side state of this connection. Doesn't work for MySQL versions older than 4.0.6 or if isParanoid() is set (it will become a no-op in these cases). Usually only used from connection pooling code.

Specified by:

resetServerState in interface Connection

Throws:

SQLException - if the operation fails while resetting server state.

rollback

public void rollback()
              throws SQLException

The method rollback() drops all changes made since the previous commit/rollback and releases any database locks currently held by the Connection.

Specified by:

rollback in interface Connection

Throws:

SQLException - if a database access error occurs

See Also:

• commit()

rollback

public void rollback(Savepoint savepoint)
              throws SQLException

Specified by:

rollback in interface Connection

Throws:

SQLException

See Also:

• Connection.rollback(Savepoint)

serverPrepareStatement

public PreparedStatement serverPrepareStatement(String sql)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

serverPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String)

serverPrepareStatement

public PreparedStatement serverPrepareStatement(String sql,
 int autoGenKeyIndex)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

serverPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int)

serverPrepareStatement

public PreparedStatement serverPrepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

serverPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int, int)

serverPrepareStatement

public PreparedStatement serverPrepareStatement(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

serverPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int, int, int)

serverPrepareStatement

public PreparedStatement serverPrepareStatement(String sql,
 int[] autoGenKeyIndexes)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

serverPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, int[])

serverPrepareStatement

public PreparedStatement serverPrepareStatement(String sql,
 String[] autoGenKeyColNames)
                                         throws SQLException

Description copied from interface: Connection

Prepares a statement on the server (irregardless of the configuration property 'useServerPrepStmts') with the same semantics as the java.sql.Connection.prepareStatement() method with the same argument types.

Specified by:

serverPrepareStatement in interface Connection

Throws:

SQLException

See Also:

• Connection.prepareStatement(String, String[])

serverSupportsConvertFn

public boolean serverSupportsConvertFn()
                                throws SQLException

Specified by:

serverSupportsConvertFn in interface MySQLConnection

Throws:

SQLException

setAutoCommit

public void setAutoCommit(boolean autoCommitFlag)
                   throws SQLException

If a connection is in auto-commit mode, than all its SQL statements will be executed and committed as individual transactions. Otherwise, its SQL statements are grouped into transactions that are terminated by either commit() or rollback(). By default, new connections are in auto-commit mode. The commit occurs when the statement completes or the next execute occurs, whichever comes first. In the case of statements returning a ResultSet, the statement completes when the last row of the ResultSet has been retrieved or the ResultSet has been closed. In advanced cases, a single statement may return multiple results as well as output parameter values. Here the commit occurs when all results and output param values have been retrieved.

Specified by:

setAutoCommit in interface Connection

Parameters:

autoCommitFlag - true enables auto-commit; false disables it

Throws:

SQLException - if a database access error occurs

setCatalog

public void setCatalog(String catalog)
                throws SQLException

A sub-space of this Connection's database may be selected by setting a catalog name. If the driver does not support catalogs, it will silently ignore this request

Note: MySQL's notion of catalogs are individual databases.

Specified by:

setCatalog in interface Connection

Parameters:

catalog - the database for this connection to use

Throws:

SQLException - if a database access error occurs

setFailedOver

public void setFailedOver(boolean flag)

Specified by:

setFailedOver in interface Connection

Parameters:

failedOver - The failedOver to set.

setHoldability

public void setHoldability(int arg0)
                    throws SQLException

Specified by:

setHoldability in interface Connection

Throws:

SQLException

See Also:

• Connection.setHoldability(int)

setInGlobalTx

public void setInGlobalTx(boolean flag)

Description copied from interface: Connection

Set the state of being in a global (XA) transaction.

Specified by:

setInGlobalTx in interface Connection

Parameters:

flag -

setPreferSlaveDuringFailover

@Deprecated
public void setPreferSlaveDuringFailover(boolean flag)

Deprecated.

Specified by:

setPreferSlaveDuringFailover in interface Connection

Parameters:

preferSlaveDuringFailover - The preferSlaveDuringFailover to set.

setReadInfoMsgEnabled

public void setReadInfoMsgEnabled(boolean flag)

Specified by:

setReadInfoMsgEnabled in interface MySQLConnection

setReadOnly

public void setReadOnly(boolean readOnlyFlag)
                 throws SQLException

You can put a connection in read-only mode as a hint to enable database optimizations Note: setReadOnly cannot be called while in the middle of a transaction

Specified by:

setReadOnly in interface Connection

Parameters:

readOnlyFlag - - true enables read-only mode; false disables it

Throws:

SQLException - if a database access error occurs

setReadOnlyInternal

public void setReadOnlyInternal(boolean readOnlyFlag)
                         throws SQLException

Specified by:

setReadOnlyInternal in interface MySQLConnection

Throws:

SQLException

setSavepoint

public Savepoint setSavepoint()
                       throws SQLException

Specified by:

setSavepoint in interface Connection

Throws:

SQLException

See Also:

• Connection.setSavepoint()

setSavepoint

public Savepoint setSavepoint(String name)
                       throws SQLException

Specified by:

setSavepoint in interface Connection

Throws:

SQLException

See Also:

• Connection.setSavepoint(String)

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws SQLException

Specified by:

setTransactionIsolation in interface Connection

Parameters:

level -

Throws:

SQLException

setTypeMap

public void setTypeMap(Map<String,Class<?>> map)
                throws SQLException

JDBC 2.0 Install a type-map object as the default type-map for this connection

Specified by:

setTypeMap in interface Connection

Parameters:

map - the type mapping

Throws:

SQLException - if a database error occurs.

shutdownServer

public void shutdownServer()
                    throws SQLException

Used by MiniAdmin to shutdown a MySQL server

Specified by:

shutdownServer in interface Connection

Specified by:

shutdownServer in interface MySQLConnection

Throws:

SQLException - if the command can not be issued.

supportsIsolationLevel

public boolean supportsIsolationLevel()

Description copied from interface: Connection

Does the server this connection is connected to support isolation levels?

Specified by:

supportsIsolationLevel in interface Connection

supportsQuotedIdentifiers

public boolean supportsQuotedIdentifiers()

Description copied from interface: Connection

Does the server this connection is connected to support quoted identifiers?

Specified by:

supportsQuotedIdentifiers in interface Connection

supportsTransactions

public boolean supportsTransactions()

Description copied from interface: Connection

Does the server this connection is connected to support transactions?

Specified by:

supportsTransactions in interface Connection

unregisterStatement

public void unregisterStatement(Statement stmt)

Remove the given statement from the list of open statements

Specified by:

unregisterStatement in interface MySQLConnection

Parameters:

stmt - the Statement instance to remove

useAnsiQuotedIdentifiers

public boolean useAnsiQuotedIdentifiers()

Specified by:

useAnsiQuotedIdentifiers in interface MySQLConnection

versionMeetsMinimum

public boolean versionMeetsMinimum(int major,
 int minor,
 int subminor)
                            throws SQLException

Description copied from interface: Connection

Does the server this connection is connected to meet or exceed the given version?

Specified by:

versionMeetsMinimum in interface Connection

Throws:

SQLException

getCachedMetaData

public CachedResultSetMetaData getCachedMetaData(String sql)

Returns cached metadata (or null if not cached) for the given query, which must match _exactly_. This method is synchronized by the caller on getMutex(), so if calling this method from internal code in the driver, make sure it's synchronized on the mutex that guards communication with the server.

Specified by:

getCachedMetaData in interface MySQLConnection

Parameters:

sql - the query that is the key to the cache

Returns:

metadata cached for the given SQL, or none if it doesn't exist.

initializeResultsMetadataFromCache

public void initializeResultsMetadataFromCache(String sql,
 CachedResultSetMetaData cachedMetaData,
 ResultSetInternalMethods resultSet)
                                        throws SQLException

Caches CachedResultSetMetaData that has been placed in the cache using the given SQL as a key. This method is synchronized by the caller on getMutex(), so if calling this method from internal code in the driver, make sure it's synchronized on the mutex that guards communication with the server.

Specified by:

initializeResultsMetadataFromCache in interface MySQLConnection

Parameters:

sql - the query that the metadata pertains too.

cachedMetaData - metadata (if it exists) to populate the cache.

resultSet - the result set to retreive metadata from, or apply to.

Throws:

SQLException

getStatementComment

public String getStatementComment()

Returns the comment that will be prepended to all statements sent to the server.

Specified by:

getStatementComment in interface Connection

Specified by:

getStatementComment in interface MySQLConnection

Returns:

the comment that will be prepended to all statements sent to the server.

setStatementComment

public void setStatementComment(String comment)

Sets the comment that will be prepended to all statements sent to the server. Do not use slash-star or star-slash tokens in the comment as these will be added by the driver itself.

Specified by:

setStatementComment in interface Connection

Parameters:

comment - the comment that will be prepended to all statements sent to the server.

reportQueryTime

public void reportQueryTime(long millisOrNanos)

Specified by:

reportQueryTime in interface Connection

isAbonormallyLongQuery

public boolean isAbonormallyLongQuery(long millisOrNanos)

Description copied from interface: MySQLConnection

Update statistics that allows the driver to determine if a query is slow enough to be logged, and return the estimation result for millisOrNanos value.

Used in case autoSlowLog=true.

Specified by:

isAbonormallyLongQuery in interface Connection

Specified by:

isAbonormallyLongQuery in interface MySQLConnection

Parameters:

millisOrNanos - query execution time

Returns:

true if millisOrNanos is outside the 99th percentile?

initializeExtension

public void initializeExtension(Extension ex)
                         throws SQLException

Specified by:

initializeExtension in interface Connection

Throws:

SQLException

transactionBegun

public void transactionBegun()
                      throws SQLException

Specified by:

transactionBegun in interface MySQLConnection

Throws:

SQLException

transactionCompleted

public void transactionCompleted()
                          throws SQLException

Specified by:

transactionCompleted in interface MySQLConnection

Throws:

SQLException

storesLowerCaseTableName

public boolean storesLowerCaseTableName()

Specified by:

storesLowerCaseTableName in interface MySQLConnection

getExceptionInterceptor

public ExceptionInterceptor getExceptionInterceptor()

Specified by:

getExceptionInterceptor in interface ConnectionProperties

Specified by:

getExceptionInterceptor in interface MySQLConnection

Overrides:

getExceptionInterceptor in class ConnectionPropertiesImpl

getRequiresEscapingEncoder

public boolean getRequiresEscapingEncoder()

Specified by:

getRequiresEscapingEncoder in interface MySQLConnection

isServerLocal

public boolean isServerLocal()
                      throws SQLException

Description copied from interface: Connection

Is the server this connection is connected to "local" (i.e. same host) as the application?

Specified by:

isServerLocal in interface Connection

Throws:

SQLException

getSessionMaxRows

public int getSessionMaxRows()

Returns the sql select limit max-rows for this session.

Specified by:

getSessionMaxRows in interface Connection

setSessionMaxRows

public void setSessionMaxRows(int max)
                       throws SQLException

Sets the sql select limit max-rows for this session if different from current.

Specified by:

setSessionMaxRows in interface Connection

Parameters:

max - the new max-rows value to set.

Throws:

SQLException - if a database error occurs issuing the statement that sets the limit.

setSchema

public void setSchema(String schema)
               throws SQLException

Specified by:

setSchema in interface Connection

Specified by:

setSchema in interface Connection

Throws:

SQLException

getSchema

public String getSchema()
                 throws SQLException

Specified by:

getSchema in interface Connection

Specified by:

getSchema in interface Connection

Throws:

SQLException

abort

public void abort(Executor executor)
           throws SQLException

Terminates an open connection. Calling abort results in:

• The connection marked as closed
• Closes any physical connection to the database
• Releases resources used by the connection
• Insures that any thread that is currently accessing the connection will either progress to completion or throw an SQLException.

Calling abort marks the connection closed and releases any resources. Calling abort on a closed connection is a no-op.

It is possible that the aborting and releasing of the resources that are held by the connection can take an extended period of time. When the abort method returns, the connection will have been marked as closed and the Executor that was passed as a parameter to abort may still be executing tasks to release resources.

This method checks to see that there is an SQLPermission object before allowing the method to proceed. If a SecurityManager exists and its checkPermission method denies calling abort, this method throws a java.lang.SecurityException.

Specified by:

abort in interface Connection

Specified by:

abort in interface Connection

Parameters:

executor - The Executor implementation which will be used by abort.

Throws:

SQLException - if a database access error occurs or the executor is null,

SecurityException - if a security manager exists and its checkPermission method denies calling abort

Since:

1.7

See Also:

• SecurityManager.checkPermission(Permission)
• Executor

setNetworkTimeout

public void setNetworkTimeout(Executor executor,
 int milliseconds)
                       throws SQLException

Specified by:

setNetworkTimeout in interface Connection

Specified by:

setNetworkTimeout in interface Connection

Throws:

SQLException

getNetworkTimeout

public int getNetworkTimeout()
                      throws SQLException

Specified by:

getNetworkTimeout in interface Connection

Specified by:

getNetworkTimeout in interface Connection

Throws:

SQLException

getProfilerEventHandlerInstance

public com.mysql.jdbc.profiler.ProfilerEventHandler getProfilerEventHandlerInstance()

Specified by:

getProfilerEventHandlerInstance in interface MySQLConnection

setProfilerEventHandlerInstance

public void setProfilerEventHandlerInstance(com.mysql.jdbc.profiler.ProfilerEventHandler h)

Specified by:

setProfilerEventHandlerInstance in interface MySQLConnection

isServerTruncatesFracSecs

public boolean isServerTruncatesFracSecs()

Specified by:

isServerTruncatesFracSecs in interface MySQLConnection

getQueryTimingUnits

public String getQueryTimingUnits()

Specified by:

getQueryTimingUnits in interface MySQLConnection