达梦数据库指定当前模式名

原创 LeeWen2020 2021-07-09

10249

在使用达梦数据库时，可能存在一个用户下有多个模式（schema）的情况，当用户登录之后访问非默认模式下的表等对象时，需要使用"模式名.对象名"的方式进行访问等操作，或者可以执行alter session set current_schema=模式名;或者SET SCHEMA <模式名>;指定当前模式。
有时候可能从SQLSERVER或者MYSQL数据库中迁移到达梦数据库时，没有创建与每个数据库对应的梦数据库用户，可能在使用达梦迁移工具迁移时直接将所有MYSQL中的数据库迁移到一个达梦数据库用户下的不同模式中（默认是模式名与MYSQL中数据库名相同）。这种情况下使用达梦数据库用户登录之后访问非默认模式下的对象时，需要"模式名.对象名"的方式，这样对与程序来说可能代码修改量比较大。针对这种情况，在达梦数据库中可以通过指定JDBC URL中的schema属性配置来指定当前模式。

简单演示

SQL语句指定用户当前模式

语句：ALTER SESSIONS SET CURRENT_SCHEMA=模式名; 或者 set schema 模式名；

查询用户下拥有的模式：

select  USERNAME,NAME AS SCHEMA_NAME,TYPE$ 
FROM SYSOBJECTS A,DBA_USERS B 
WHERE A.PID=B.USER_ID AND A.TYPE$='SCH' AND B.USERNAME='TEST';
------------------------------------------------------------------------
#查看TEST用户下的模式：
[dmdba@localhost bin]$ ./disql /nolog
disql V8
SQL> login
服务名:
用户名:TEST
密码:
SSL路径:
SSL密码:
UKEY名称:
UKEY PIN码:
MPP类型:
是否读写分离(y/n):
协议类型:

服务器[LOCALHOST:5236]:处于普通打开状态
登录使用时间 : 2.850(ms)
SQL> select  USERNAME,NAME AS SCHEMA_NAME,TYPE$ FROM SYSOBJECTS A,DBA_USERS B WHERE A.PID=B.USER_ID AND A.TYPE$='SCH' AND B.USERNAME='TEST';

行号     USERNAME SCHEMA_NAME TYPE$
---------- -------- ----------- -----
1          TEST     TEST        SCH        ###TEST用户下有TEST、TEST2两个模式
2          TEST     TEST2       SCH

已用时间: 18.982(毫秒). 执行号:701.
------------------------
复制

查看当前模式：

#默认模式名与用户名相同，且用户登录之后不指定当前模式或者操作的对象前不加模式名“模式名.对象名”，默认是操作默认模式下的对象；
----------
#查看用户会话当前的模式名：
SQL> SELECT SF_GET_SCHEMA_NAME_BY_ID(CURRENT_SCHID);

行号     SF_GET_SCHEMA_NAME_BY_ID(CURRENT_SCHID)
---------- ---------------------------------------
1          TEST
或者:
SQL> select sys_context('USERENV','CURRENT_SCHEMA');

行号     SYS_CONTEXT('USERENV','CURRENT_SCHEMA')
---------- ---------------------------------------
1          TEST
复制

指定当前模式：

SQL> alter session set current_schema=TEST2; 
或者
SQL> set schema TEST2;

SQL> select sys_context('USERENV','CURRENT_SCHEMA');

行号     SYS_CONTEXT('USERENV','CURRENT_SCHEMA')
---------- ---------------------------------------
1          TEST2

或者
SQL> SELECT SF_GET_SCHEMA_NAME_BY_ID(CURRENT_SCHID);

行号     SF_GET_SCHEMA_NAME_BY_ID(CURRENT_SCHID)
---------- ---------------------------------------
1          TEST2
复制

查看当前模式的对象：
查看模式下拥有的对象，可以通过DBA_OBJECTS、ALL_OBJECTS、SYSOBJECTS等视图根据OWNER='模式名’去查看。需要注意的是，user_tables等USER视图是查看当前用户下所有模式的对象。

JDBC中指定用户当前模式

JDBC URL属性为：schema，指定用户登录后的当前模式，默认为用户的默认模式。

JDBC URL为：jdbc:dm://ip:port?schema=模式名

简单测试示例如下：

在TEST用户TEST2模式下创建表并插入数据，然后查询：

String name="dm.jdbc.driver.DmDriver";
String url="jdbc:dm://192.168.15.35:5236?schema=TEST2";     //使用schema指定当前模式名
String user="TEST";
String password="123456789";
复制

简单的建表、插入数据、查询

class Table extends Connec{
    public void create() throws SQLException{
        String sql_1="DROP TABLE TABLE1;";
        String sql_2="CREATE TABLE TABLE1(C1 INT,C2 VARCHAR(50));";            //创建表TABLE1
        Connection testcon=getConn();
        Statement state=testcon.createStatement();
        try{
            state.executeUpdate(sql_2);
        }catch(SQLException e){
            state.executeUpdate(sql_1);
            state.executeUpdate(sql_2);
        }
        System.out.print("建表成功" + "\n");
        state.close();
        testcon.close();
    }

    public void insert() throws SQLException{
    	String sql="INSERT INTO TABLE1 SELECT 1,SF_GET_SCHEMA_NAME_BY_ID(CURRENT_SCHID);";    //插入一条数据其中一个值为当前模式名
        Connection testcon=getConn();
        PreparedStatement pre=testcon.prepareStatement(sql);
        try{
            pre.executeUpdate();
        }catch(SQLException e){
            System.out.print(e);
        }
        System.out.print("插入成功" + "\n");
        pre.close();
        testcon.close();
    }
    public void select() throws SQLException{
        String sql="SELECT * from TABLE1;";
        Connection testcon=getConn();
        Statement state=testcon.createStatement();
        ResultSet res=state.executeQuery(sql);
        while(res.next()){
            System.out.print("查询结果：" + "\n");
            System.out.println(
                res.getInt(1)+","+
                res.getString(2)
            );
        }
    }
}
public class GetTable {
    public static void main(String[] args) {
        Table table=new Table();
        try{
            table.create();   
            table.insert(); 
            table.select();
        }catch(SQLException e){
            System.out.println(e);
        }
        
    }
}
复制

执行结果：