From a7f4e2784e1bcc81b00568bce7d4901285d7c664 Mon Sep 17 00:00:00 2001 From: Tang Cheng Date: Tue, 22 Oct 2019 10:49:00 +0800 Subject: [PATCH] =?utf8?q?=E5=A2=9E=E5=8A=A0=20tenant=20datasource=20conne?= =?utf8?q?ction=20=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- .../framework/tenant/MultiTenantConnectionProviderImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/payapi/src/main/java/com/supwisdom/dlpay/framework/tenant/MultiTenantConnectionProviderImpl.java b/payapi/src/main/java/com/supwisdom/dlpay/framework/tenant/MultiTenantConnectionProviderImpl.java index a8f8dd57..0666b657 100644 --- a/payapi/src/main/java/com/supwisdom/dlpay/framework/tenant/MultiTenantConnectionProviderImpl.java +++ b/payapi/src/main/java/com/supwisdom/dlpay/framework/tenant/MultiTenantConnectionProviderImpl.java @@ -1,8 +1,8 @@ package com.supwisdom.dlpay.framework.tenant; import com.supwisdom.dlpay.framework.util.StringUtil; +import lombok.extern.slf4j.Slf4j; import org.hibernate.HibernateException; -import org.hibernate.engine.jdbc.connections.spi.AbstractDataSourceBasedMultiTenantConnectionProviderImpl; import org.hibernate.engine.jdbc.connections.spi.MultiTenantConnectionProvider; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -14,6 +14,7 @@ import java.sql.SQLException; /** * Created by shuwei on 2018/12/4. */ +@Slf4j @Component public class MultiTenantConnectionProviderImpl implements MultiTenantConnectionProvider { @Autowired @@ -35,8 +36,10 @@ public class MultiTenantConnectionProviderImpl implements MultiTenantConnectionP final Connection connection = getAnyConnection(); try { if (!StringUtil.isEmpty(tenantIdentifier)) { + log.debug("postgresql set search path to <" + tenantIdentifier + ">"); connection.createStatement().execute("SET search_path = \"" + tenantIdentifier + "\", public"); } else { + log.debug("postgresql set search path to public"); connection.createStatement().execute("SET search_path = public"); } } catch (SQLException e) { -- 2.17.1