如何使用 pl*sql​​ developer 运行 .sql 文件？

Question

我正在尝试使用 Java 连接 pl*sql​​ 开发人员工具，我想在其中运行 SQL 查询。我知道如何使用 Java 在 Oracle 数据库中运行 sql 查询，但无法使用 pl*sql​​ developer 运行。我的 Oracle 数据库安装在另一台服务器上。

以下是我使用 Java 进行数据库连接的代码。

import java.sql.*;
import java.util.*;


public class DatabaseConnectivity {

private static final String DEFAULT_DRIVER = "oracle.jdbc.driver.OracleDriver";
private static final String DEFAULT_URL = "jdbc:oracle:thin:@localhost:1521/XE";
private static final String DEFAULT_USERNAME = "appuser";
private static final String DEFAULT_PASSWORD = "vivek123";


public static void main(String[] args)
{
    long begTime = System.currentTimeMillis();

    String driver = ((args.length > 0) ? args[0] : DEFAULT_DRIVER);
    String url = ((args.length > 1) ? args[1] : DEFAULT_URL);
    String username = ((args.length > 2) ? args[2] : DEFAULT_USERNAME);
    String password = ((args.length > 3) ? args[3] : DEFAULT_PASSWORD);

    Connection connection = null;

    try
    {
        connection = createConnection(driver, url, username, password);
        DatabaseMetaData meta = connection.getMetaData();
        System.out.println(meta.getDatabaseProductName());
        System.out.println(meta.getDatabaseProductVersion()); 

        String sqlQuery = "select * from student";
        connection.commit();
        
        System.out.println(query(connection, sqlQuery, Collections.EMPTY_LIST));
    }
    catch (Exception e)
    {
        rollback(connection);
        e.printStackTrace();
    }
    finally
    {
        close(connection);
        long endTime = System.currentTimeMillis();
     //   System.out.println("wall time: " + (endTime - begTime) + " ms");
    }
}
public static Connection createConnection(String driver, String url, String username, String password) throws ClassNotFoundException, SQLException
{
    Class.forName(driver);

    if ((username == null) || (password == null) || (username.trim().length() == 0) || (password.trim().length() == 0))
    {
        return DriverManager.getConnection(url);
    }
    else
    {
        return DriverManager.getConnection(url, username, password);
    }
}
public static void close(Connection connection)
{
    try
    {
        if (connection != null)
        {
            connection.close();
        }
    }
    catch (SQLException e)
    {
        e.printStackTrace();
    }
}

public static void close(Statement st)
{
    try
    {
        if (st != null)
        {
            st.close();
        }
    }
    catch (SQLException e)
    {
        e.printStackTrace();
    }
}

public static void close(ResultSet rs)
{
    try
    {
        if (rs != null)
        {
            rs.close();
        }
    }
    catch (SQLException e)
    {
        e.printStackTrace();
    }
}

public static void rollback(Connection connection)
{
    try
    {
        if (connection != null)
        {
            connection.rollback();
        }
    }
    catch (SQLException e)
    {
        e.printStackTrace();
    }
}

public static List<Map<String, Object>> map(ResultSet rs) throws SQLException
{
    List<Map<String, Object>> results = new ArrayList<Map<String, Object>>();

    try
    {
        if (rs != null)
        {
            ResultSetMetaData meta = rs.getMetaData();
            int numColumns = meta.getColumnCount();
            while (rs.next())
            {
                Map<String, Object> row = new HashMap<String, Object>();
                for (int i = 1; i <= numColumns; ++i)
                {
                    String name = meta.getColumnName(i);
                    Object value = rs.getObject(i);
                    row.put(name, value);
                }
                results.add(row);
            }
        }
    }
    finally
    {
        close(rs);
    }

    return results;
}

public static List<Map<String, Object>> query(Connection connection, String sql, List<Object> parameters) throws SQLException
{
    List<Map<String, Object>> results = null;

    PreparedStatement ps = null;
    ResultSet rs = null;

    try
    {
        ps = connection.prepareStatement(sql);

        int i = 0;
        for (Object parameter : parameters)
        {
            ps.setObject(++i, parameter);
        }

        rs = ps.executeQuery();
        results = map(rs);
    }
    finally
    {
        close(rs);
        close(ps);
    }

    return results;
}

public static int update(Connection connection, String sql, List<Object> parameters) throws SQLException
{
    int numRowsUpdated = 0;

    PreparedStatement ps = null;

    try
    {
        ps = connection.prepareStatement(sql);

        int i = 0;
        for (Object parameter : parameters)
        {
            ps.setObject(++i, parameter);
        }

        numRowsUpdated = ps.executeUpdate();
    }
    finally    
    {    
        close(ps);    
    }    

    return numRowsUpdated;    
}
}

Answer 1

你提到了“oracle database in another server”那为什么Driver Url中有localhost呢？

Answer 2

基本上，您希望在远程 oracle 数据库上运行查询。为此，您只需要传递数据库连接详细信息，例如 ip 地址/主机名、端口、数据库名称和用户/密码。

仍然不确定“从 java 代码连接 plsql 开发人员”是什么意思？ Plsql 开发人员还使用 JDBC 代码连接到任何 oracle 数据库，就像您使用 JDBC 代码一样。

Answer 3

您应该在 java 代码中使用与在 pl*sql​​ 开发人员中使用的相同的凭据。如果您使用 JDBC，Java 代码可以是所有数据库的通用代码。

我认为没有为 pl*sql​​ 提供任何可以通过 java 代码调用的后端 api。