1.选择UDW标签可以跳转到UDW操作界面（如果没有这个标签，请联系客服申请开通），点击欢迎页的“开始探索”，然后点击“创建数据仓库”。

2.选择计算节点机型、计算节点数量以及付费方式。

其中可选的机型配置有：

选择数据仓库类型：Greenplum是EMC开源的数据仓库产品、Udpg是基于PostgreSQL开发的大规模并行、完全托管的PB级数据仓库服务。

选择节点个数：UDW是分布式架构、所有节点数据都是双机热备,实际可用总容量略小于节点个数*节点磁盘大小/2，请根据实际数据大小选择合适的节点。

3.设置数据仓库信息 必选项有数据仓库名称、DB管理员用户名、管理员密码。可选项有默认DB,默认DB的名称为dev，你可以选择除了“test”、“postgres”、“template ”、“template0”、“template1” 、“default”之外的其他名称。 DB管理员用户名不能为“postgres”。端口固定为5432，暂不提供修改。

4.确认支付

5.等待部署中 数据仓库规模不同，所需要的部署时间会有所差异。

如上图所示客户端访问管理，提供了客户端下载和数据加载工具和文档的下载。

Linux操作系统

yum install postgresql-jdbc.noarch –y 

Windows环境下JDBC驱动，将jar添加到工程的BUILD PATH。

• 示例程序1，java连接UDW，执行建表，插入操作

PostgreSQLJDBC1.java

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class PostgreSQLJDBC1 {
    public static void main(String args[]) {
        Connection c = null;
        Statement stmt = null;
        try {
            Class.forName("org.postgresql.Driver");
            c = DriverManager.getConnection("jdbc:postgresql://hostIP:port/dbname",”UserName”,”Password”);
            stmt = c.createStatement();
            String sql = "CREATE TABLE COMPANY " + "(ID INT PRIMARY KEY NOT NULL," + "NAME TEXT NOT NULL," + "AGE INT NOT NULL," + "ADDRESS CHAR(50)," + "SALARY REAL)";
        c.setAutoCommit(false);
        System.out.println("Opened database successfully");
        stmt.executeUpdate(sql);
        sql = "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) " + "VALUES (1, 'Allen', 25 , 'Texas', 15000.00 );"; 
        stmt.executeUpdate(sql); 
        stmt.close();
        c.commit();
        c.close();
        }   
        catch (Exception e) {
            e.printStackTrace();
            System.err.println(e.getClass().getName()+": "+e.getMessage());
            System.exit(0);
        }
        System.out.println("Opened database successfully");
    }
}

• 示例程序二：java连接UDW，执行查询操作

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class PostgreSQLJDBC2 {
     public static void main(String[] args) {
         Connection c = null; 
         Statement stmt = null;
         try{
             Class.forName("org.postgresql.Driver");
             c = DriverManager.getConnection("jdbc:postgresql://hostIP:port/dbname",”UserName”,”Password”);
             stmt = c.createStatement();
             String sql = null;
             System.out.println("Opened database successfully");
             sql = "SELECT * FROM COMPANY;";
             ResultSet res=stmt.executeQuery(sql);
             while(res.next()) {
                 System.out.println(res.getInt(1));
                 System.out.println(res.getString(2));
                 System.out.println(res.getInt(3));
                 System.out.println(res.getString(4));
                 System.out.println(res.getDouble(5));
             }
             stmt.close();
             c.close();
         }
         catch(Exception e) {
             System.err.println( e.getClass().getName()+": "+ e.getMessage() );
             System.exit(0);
         }
     }
 }

Linux操作系统：CentOS 6.5 64位

• 安装 postgresql odbc驱动

yum install postgresql-odbc.x86_64 -y

1. 编辑odbcinst.ini文件，配置odbc驱动

vim  /etc/odbcinst.ini
 
Description    = ODBC for PostgreSQL
Driver         = /usr/lib/psqlodbc.so
Setup          = /usr/lib/libodbcpsqlS.so
Driver64       = /usr/lib64/psqlodbc.so
Setup64        = /usr/lib64/libodbcpsqlS.so
FileUsage      = 1

• 测试ODBC驱动是否安装成功

# odbcinst -q -d
[PostgreSQL]

如果出现以上输出，代表在这台机器上已成功安装了PostgreSQL的ODBC驱动。

• 编辑/etc/odbc.int文件配置ODBC连接

[testdb]Description  = PostgreSQL connection to TestDB
Driver               = PostgreSQL
Database             = Database
Servername           = MasterNodeIP
UserName             = UserName
Password             = Password
Port                 = Port
Protocol             = 8.3
ReadOnly             = No
RowVersioning        = NoShow
SystemTables         = No
ConnSettings         = 

• 测试连接

isql testdb

注解：
如出现以上内容，则表示psqlodbc配置成功。

1.udw客户端的方式访问

1.1 udw（greenplum）客户端方式访问（以Centos为例）

如果你选择的数据仓库类型是greenplum、可以采用下面的方式访问

1）下载greenplum客户端解压

wget http://udwclient.cn-bj.ufileos.com/greenplum-client.tar.gz

tar -zxvf greenplum-client.tar.gz

2）配置udw客户端

进入greenplum-client安装目录，编辑 greenplumclientpath.sh 修改UDWHOME:export UDWHOME= client安装目录（如/root/greenplum-client）

3） 使配置生效

在~/.bashrc中添加如下配置

source /data/greenplum-client/greenplumclientpath.sh

source ~/.bashrc

备注：/data/greenplum-client是greenplum-client的安装路径

4） 连接数据库

psql -h hostIP（或域名） –U username -d database -p port –W

1.2 udw（udpg）客户端方式访问（以Centos为例）

如果你选择的数据仓库类型是udpg、可以采用下面的方式访问

1）下载udw客户端

wget http://udwclient.ufile.auto-ai.com.cn/udw-client.tar

解压: tar xvf udw-client.tar

2）配置udw客户端

进入udw-client安装目录，编辑 udwclientpath.sh，修改UDWCLIENT:export UDWCLIENT= client安装目录（如/root/udw-client）

3）使配置生效在~/.bashrc中添加如下配置

source /data/udw-client/udw_client_path.sh
source ~/.bashrc

备注：/data/udw-client是udw-client的安装路径

4） 连接数据库

psql -h hostIP（或域名） –U username -d database -p port –W

2.python客户端访问

$yum install python-psycopg2

示例1. 连接UDW testconn.py

#!/usr/bin/python
 
import psycopg2
conn = psycopg2.connect(database="dev", user="username", password="password", host="hostIP", port="port")
print "Opened database successfully"

执行 python testconn.py

示例2. 创建一个表 createTable.py

#!/usr/bin/python
 
import psycopg2
conn = psycopg2.connect(database="dev", user="username", password="password", host="hostIP", port="port")
print "Opened database successfully"
cur = conn.cursor()
cur.execute('''CREATE TABLE COMPANY
    (ID INT PRIMARY KEY     NOT NULL,
    NAME           TEXT    NOT NULL,
    AGE            INT     NOT NULL,
    ADDRESS        CHAR(50),
    SALARY         REAL);''')
 print "Table created successfully"
 conn.commit()
 conn.close()

示例3. 插入记录 insert.py

#!/usr/bin/python
 
import psycopg2
conn = psycopg2.connect(database="dev", user="username", password="password", host="hostIP", port="port")
print "Opened database successfully"
cur = conn.cursor()
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
  VALUES (1, 'Paul', 32, 'California', 20000.00 )");
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
  VALUES (2, 'Allen', 25, 'Texas', 15000.00 )");
conn.commit()
print "Records created successfully";
conn.close() 

示例4. 查询 select.py

#!/usr/bin/python
 
import psycopg2
conn = psycopg2.connect(database="dev", user="username", password="password", host="hostIP", port="port")
print "Opened database successfully"
cur = conn.cursor()
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows = cur.fetchall()
for row in rows:
    print "ID = ", row[0]
    print "NAME = ", row[1]
    print "ADDRESS = ", row[2]
    print "SALARY = ", row[3], "\n"
print "Operation done successfully";
conn.close()  

示例5. 更新 update.py

#!/usr/bin/python
 
import psycopg2
conn = psycopg2.connect(database="dev", user="username", password="password", host="hostIP", port="port")
print "Opened database successfully"
cur = conn.cursor()
cur.execute("UPDATE COMPANY set SALARY = 25000.00 where ID=1")
conn.commit
print "Total number of rows updated :", cur.rowcount
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows = cur.fetchall()
for row in rows:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], "\n"
 print "Operation done successfully";
 conn.close()  

示例6. 删除 delete.py

#!/usr/bin/python
 
import psycopg2
conn = psycopg2.connect(database="dev", user="username", password="password", host="hostIP", port="port")
print "Opened database successfully"
cur = conn.cursor()
cur.execute("DELETE from COMPANY where ID=2;")
conn.commit
print "Total number of rows deleted :", cur.rowcount
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows = cur.fetchall()
for row in rows:
    print "ID = ", row[0]
    print "NAME = ", row[1]
    print "ADDRESS = ", row[2]
    print "SALARY = ", row[3], "\n"
print "Operation done successfully";
conn.close()  

3.php客户端

yum install php-pgsql

示例1. 连接 conn.php

undefined        = "host=hostIP";
undefined        = "port=port";
undefined      = "dbname=dbname";
undefined = "user=user password=password";
undefined = pg_connect( "undefined undefined undefined undefined"  );
if(!undefined){
      echo "Error : Unable to open database\n";
} else {
  echo "Opened database successfully\n";
}
?>

示例2. 创建表 create.php

undefined        = "host=hostIP";
undefined        = "port=port";
undefined      = "dbname=dbname";
undefined = "user=user password=password";
undefined = pg_connect( "undefined undefined undefined undefined"  );
if(!undefined){
    echo "Error : Unable to open database\n";
} else {
    echo "Opened database successfully\n";
} 
undefined =<<; 
undefined = pg_query(undefined, undefined); 
if(!undefined)
	{ echo pg_last_error(undefined); 
        } else {
          echo "Table created successfullyn"; 
        } 
pg_close(undefined); 
?>

示例3. 插入 insert.php

undefined        = "host=hostIP";
undefined        = "port=port";
undefined      = "dbname=dbname";
undefined = "user=user password=password";
undefined = pg_connect( "undefined undefined undefined undefined"  );
if(!undefined){
   echo "Error : Unable to open database\n";
} else {
   echo "Opened database successfully\n";
}
undefined =<<;
undefined = pg_query(undefined, undefined);
if(!undefined){
   echo pg_last_error(undefined);
} else {
   echo "Records created successfully\n";
}
pg_close(undefined);
?>

示例4. 查询 select.php

undefined        = "host=hostIP";
undefined        = "port=port";
undefined      = "dbname=dbname";
undefined = "user=user password=password";
undefined = pg_connect( "undefined undefined undefined undefined"  );
if(!undefined){
   echo "Error : Unable to open database\n";
} else {
   echo "Opened database successfully\n";
}
undefined =<<;
undefined = pg_query(undefined, undefined);
if(!undefined){
   echo pg_last_error(undefined);
   exit;
} 
while(undefined = pg_fetch_row(undefined)){
   echo "ID = ". undefined[0] . "\n";
   echo "NAME = ". undefined[1] ."\n";
   echo "ADDRESS = ". undefined[2] ."\n";
   echo "SALARY =  ".undefined[4] ."\n\n";
}
echo "Operation done successfully\n";
pg_close(undefined);
?>

示例5. 更新 update.php

undefined        = "host=hostIP";
undefined        = "port=port";
undefined      = "dbname=dbname";
undefined = "user=user password=password";
undefined = pg_connect( "undefined undefined undefined undefined"  );
if(!undefined){
   echo "Error : Unable to open database\n";
} else {
   echo "Opened database successfully\n";
}
undefined =<<;
undefined = pg_query(undefined, undefined);
if(!undefined){
   echo pg_last_error(undefined);
   exit;
} 
while(undefined = pg_fetch_row(undefined)){
   echo "ID = ". undefined[0] . "\n";
   echo "NAME = ". undefined[1] ."\n";
   echo "ADDRESS = ". undefined[2] ."\n";
   echo "SALARY =  ".undefined[4] ."\n\n";
}
echo "Operation done successfully\n";
pg_close(undefined);
?>

示例6. 删除 delete.php

undefined        = "host=hostIP";
undefined        = "port=port";
undefined      = "dbname=dbname";
undefined = "user=user password=password";
undefined = pg_connect( "undefined undefined undefined undefined"  );
if(!undefined){
   echo "Error : Unable to open database\n";
} else {
   echo "Opened database successfully\n";
}
undefined =<<;
undefined = pg_query(undefined, undefined);
if(!undefined){
   echo pg_last_error(undefined);
   exit;
} else {
   echo "Record deleted successfully\n";
}
undefined =<<;
undefined = pg_query(undefined, undefined);
if(!undefined){
   echo pg_last_error(undefined);
   exit;
} 
while(undefined = pg_fetch_row(undefined)){
   echo "ID = ". undefined[0] . "\n";
   echo "NAME = ". undefined[1] ."\n";
   echo "ADDRESS = ". undefined[2] ."\n";
   echo "SALARY =  ".undefined[4] ."\n\n";
}
echo "Operation done successfully\n";
pg_close(undefined);
?>

4.SQL Workbench/J 访问 udw

除了以上几种方式，UDW还可以使用SQL Workbench/J来进行访问，详情可见：SQL Workbench/J 访问 udw