postgresql-42.2.5.jar
登录
|
org.postgresql:postgresql:42.2.5
META-INF
org
postgresql
core
ds
geometric
jdbc
replication
LogSequenceNumber.java
fluent
PGReplicationConnection.java
PGReplicationStream.java
ReplicationType.java
PGReplicationConnectionImpl.java
Driver.java
largeobject
PGStatement.java
PGResultSetMetaData.java
gss
util
PGRefCursorResultSet.java
osgi
ssl
PGConnection.java
jdbc3
PGNotification.java
sspi
fastpath
copy
translation
hostchooser
jdbc2
PGProperty.java
xa
jre8
PGReplicationConnectionImpl.java
清空
类结构
/* * Copyright (c) 2016, PostgreSQL Global Development Group * See the LICENSE file in the project root for more information. */ package org.postgresql.replication; import org.postgresql.core.
BaseConnection
; import org.postgresql.replication.fluent.
ChainedCreateReplicationSlotBuilder
; import org.postgresql.replication.fluent.
ChainedStreamBuilder
; import org.postgresql.replication.fluent.
ReplicationCreateSlotBuilder
; import org.postgresql.replication.fluent.
ReplicationStreamBuilder
; import java.sql.
SQLException
; import java.sql.
Statement
; public class
PGReplicationConnectionImpl
implements
PGReplicationConnection
{ private
BaseConnection
connection
; public
PGReplicationConnectionImpl
(
BaseConnection
connection
) { this.
connection
=
connection
; } @
Override
public
ChainedStreamBuilder
replicationStream
() { return new
ReplicationStreamBuilder
(
connection
); } @
Override
public
ChainedCreateReplicationSlotBuilder
createReplicationSlot
() { return new
ReplicationCreateSlotBuilder
(
connection
); } @
Override
public void
dropReplicationSlot
(
String
slotName
) throws
SQLException
{ if (
slotName
== null ||
slotName
.
isEmpty
()) { throw new
IllegalArgumentException
("Replication slot name can't be null or empty"); }
Statement
statement
=
connection
.
createStatement
(); try {
statement
.
execute
("DROP_REPLICATION_SLOT " +
slotName
); } finally {
statement
.
close
(); } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口