diff --git a/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java b/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java index 5eb3858ae0f..114ef7a99b8 100644 --- a/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java +++ b/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java @@ -101,6 +101,11 @@ public void setUp() throws Exception { statement.execute( "DROP TABLE IF EXISTS test_table; " + "CREATE TABLE test_table(id varchar(255), name varchar(255));"); + statement.execute( + "CREATE USER IF NOT EXISTS dbuser PASSWORD 'dbpassword';" + + "CREATE USER IF NOT EXISTS user1Id PASSWORD 'user1Pw';" + + "CREATE USER IF NOT EXISTS user2Id PASSWORD 'user2Pw';" + ); PreparedStatement insertStatement = connection.prepareStatement( "insert into test_table(id, name) values ('a', 'a_name'),('b', 'b_name'),('c', ?);");