是否可以连接 mysql 和 sql server 来获取其中存在的表？

Question

用户不应该指定类型是ms sql还是my sql？ 我想在netbeans 中做吗？ 如果没有的话有什么办法吗？

谢谢

Answer 1

编辑

不知何故，我认为您想知道如何开发可以处理多个数据库的应用程序。所以这是一个可以帮助你的模式。但要实际查询数据库并从中获取所需的所有数据，您将需要使用相应的 API。 （例如，用于 Java 应用程序的 JDBC）。读到这个答案的最后，我刚刚添加了一个如何将 JDBC 与实际的 Sql Server 数据库一起使用的示例。

（第一部分：如何管理持久性层）

你的程序应该有一个多层架构。这些层之一应该是将从数据库查询/检索数据的持久层。从现在开始，我只讨论这个持久层。

实现此目的的一种方法是使用 Java 接口。

public interface DataService
{
   connect();
   close();
   ArrayList<IUser> retrieveUserDatas(..);
   // other expected operations
   .... 
}

然后，为每种数据库类型都有一个该接口的实现类。因此，您将拥有：

class SqlServer implements DataService
{
   // Implementation of your operations using Sql Server drivers
}

class Mysql implements DataService
{ 
   // Implementation of your operations using Mysql drivers
}

然后您可以有一个管理器来决定您要使用哪个数据库：

class Manager
{
   DataService dataService;
   public Manager(string databaseType)
   {
       if(databaseType.equals("sqlserver"))
       {
          dataService = new SqlServer();
       }

       else if(databaseType.equals("mysql"))
       {
          dataService = new Mysql();
       }
   }
}

因此，在您的上层中，您将能够使用合适的数据库系统为持久层创建一个管理器：

Manager manager = new Manager("mysql"); // I want to manage my database layer with mysql

现在您的管理器的属性 dataService 将是 Mysql 类的实例，您将能够使用该类的操作。这只是每次向系统添加新数据库时需要更改的一行代码（+ 实现接口并使用数据库特定驱动程序的类）。

仅供参考，这是一个桥设计模式！

（第二部分：使用 JDBC）

例如，这里是 Sql Server 数据库的实现类实际上的样子：

public class SqlServerAccess implements IDataServerAccess {

    static final String url= "jdbc:sqlserver://localhost:1433;databaseName="NAME OF YOUR DATABASE";integratedSecurity=true;";
    Connection connector;


    public void connection() {
        try {
            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance();
            connector = DriverManager.getConnection(url, "root", "");
        } catch (Exception ex) {
            Logger.getLogger(SqlServerAccess.class.getName()).log(Level.SEVERE, null, ex);
        }
    }


    @Override
    public void close() {
        try {
            if(connector != null){
                connector.close();
            }
        } catch (SQLException ex) {
            Logger.getLogger(SqlServerAccess.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

在 connection() 方法中，您可以看到我引用了 Sql Server 驱动程序：com.microsoft.sqlserver.jdbc.SQLServerDrive

因此，对于每个数据库，您都需要下载一个特定的驱动程序 (.jar) 并在实现类中指定。

最后，这是插入的样子：

public void insertData(Data data) {
        try {
            Statement st = dataServerAccess.connect().createStatement();
            st.execute("INSERT INTO DATA(bla, bla, bla, bla, created_at)"
                                + "VALUES('" + data.bla()
                                + "', '" + ..
                                + "', '" + ..
                                + "', '" + ..
                                + "','"  + getTodayTimestamp() +"')");
        } catch (SQLException ex) {

        } finally {
            dataServerAccess.close();
        }
    }

希望这个解释能帮助您构建您想要的内容。您可能需要谷歌搜索所有这些关键字（例如 JDBC、数据库层，稍后您可以进一步使用 JPA，这是一个对象关系映射器。无论如何，关键字要在 Google 上检查！）。例如这里有一些文档来帮助您将 JDBC 与mysql。