(zeppelin) branch master updated: [ZEPPELIN-6003] Log source info of SQL in JDBCInterpreter (#4732)

[pdallig]

This is an automated email from the ASF dual-hosted git repository.

pdallig pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new 57331efb63 [ZEPPELIN-6003] Log source info of SQL in JDBCInterpreter 
(#4732)
57331efb63 is described below

commit 57331efb63342d5ac8d8a22519becf96c18423be
Author: Manhua <kevin...@qq.com>
AuthorDate: Thu Mar 14 21:15:36 2024 +0800

    [ZEPPELIN-6003] Log source info of SQL in JDBCInterpreter (#4732)
    
    * [ZEPPELIN-6003] Log detail info of SQL in JDBCInterpreter
    
    * Update
    
    Co-authored-by: Philipp Dallig <philipp.dal...@gmail.com>
    
    ---------
    
    Co-authored-by: Philipp Dallig <philipp.dal...@gmail.com>
---
 jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java 
b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java
index f6fed74ad0..e31c6e4a5d 100644
--- a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java
+++ b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java
@@ -763,6 +763,7 @@ public class JDBCInterpreter extends KerberosInterpreter {
     Statement statement;
     ResultSet resultSet = null;
     String paragraphId = context.getParagraphId();
+    String noteId = context.getNoteId();
     String user = getUser(context);
 
     try {
@@ -799,7 +800,7 @@ public class JDBCInterpreter extends KerberosInterpreter {
           // so we need to trim it first in this case.
           sqlToExecute = sqlToExecute.trim();
         }
-        LOGGER.info("Execute sql: " + sqlToExecute);
+        LOGGER.info("[{}|{}|{}] Execute sql: {}", user, noteId, paragraphId, 
sqlToExecute);
         statement = connection.createStatement();
 
         // fetch n+1 rows in order to indicate there's more rows available 
(for large selects)