本文主要实现使用node.js连接redis数据库，pub/sub。当有数据压入到list中时，pub消息，然后在sub端从list中取出相应的数据

pub.js

var redis = require("redis");
var client = redis.createClient();

client.lpush('usr','test:value');     //将数据压入到list usr中
client.lpush('like','test1:value1');
client.lpush('dislike','test2:value2');

client.publish("usr", 'new');
client.publish("like", 'test');
client.publish("dislike", 'test2');

sub.js

var redis = require("redis");
var fs = require("fs");

var client1 = redis.createClient();
var client2 = redis.createClient();

var len = 0;
client1.on("message", function (channel, message) {
	getValue(channel);

	/*
    	console.log(channel + ": " + message);
	fs.appendFile("./log.txt",message+'\n',function(e){ //将数据追加到日志文件中
    		if(e) throw e;
    	});
	*/
});

//var myDate = new Date();  //获取当前时间
//console.log(myDate);

client1.subscribe("usr");
client1.subscribe("like");
client1.subscribe("dislike");

function getValue(channel)
{
	client2.llen(channel,function(err,reply){ //回调函数形式获取结果，可以使用redis.print来查看结果
		//console.log(reply);
		var client = redis.createClient();
		for(var i=0;i<reply;i++)
		{
			client.rpop(channel,function(err,reply){
				console.log(reply);
			});
		}
	});
}

创建一个非分区表,注意两个表的表结构和字段类型一致.

SQL> CREATE TABLE tab_unpart
2 (
3 col1 varchar2(30),
4 col2 DATE
5 );

TABLE created.

SQL> INSERT INTO tab_unpart(col1, col2) SELECT -1, sysdate-365 FROM dual;

1 ROW created.

SQL> INSERT INTO tab_unpart(col1, col2) SELECT 0, sysdate FROM dual;

1 ROW created.

SQL> INSERT INTO tab_unpart(col1, col2) SELECT +1, sysdate+360 FROM dual;

1 ROW created.

SQL> commit;

Commit complete.

SQL> SELECT col1,to_char(col2,'yyyy-mm-dd') FROM tab_unpart;

COL TO_CHAR(CO
--- ----------
-1  2011-01-05
0   2012-01-05
1   2012-12-30

SQL> CREATE TABLE tab_part
  2  (
  3  col1 varchar2(30),
  4  col2 DATE
  5  )
  6  partition BY range(col2)
  7  (
  8  partition tab_part_2011 VALUES less than (to_date('2011-01-01','yyyy-mm-dd')),
  9  partition tab_part_2012 VALUES less than (to_date('2012-01-01','yyyy-mm-dd')),
 10  partition tab_part_2013 VALUES less than (to_date('2013-01-01','yyyy-mm-dd')),
 11  );

TABLE created.

SQL> @partition_

NAME            OBJECT COLUMN_NAME PARTITIONING_TYPE    STATUS  PARTITION_NAME
--------------- ------ ----------- -------------------- ------- ---------------
TAB_PART        TABLE  COL2        RANGE                VALID   TAB_PART_2013
TAB_PART        TABLE  COL2        RANGE                VALID   TAB_PART_2011
TAB_PART        TABLE  COL2        RANGE                VALID   TAB_PART_2012

SQL> EXEC dbms_redefinition.can_redef_table('TEST','TAB_UNPART',1);
BEGIN dbms_redefinition.can_redef_table('TEST','TAB_UNPART',1); END;

*
ERROR at line 1:
ORA-12089: cannot online redefine TABLE "TEST"."TAB_UNPART" WITH no PRIMARY KEY
ORA-06512: at "SYS.DBMS_REDEFINITION", line 139
ORA-06512: at "SYS.DBMS_REDEFINITION", line 1782
ORA-06512: at line 1

SQL> ALTER TABLE TAB_UNPART ADD CONSTRAINT pk_unpart_col1 PRIMARY KEY (COL1);

TABLE altered.

SQL> ALTER TABLE TAB_PART ADD CONSTRAINT pk_part_col1 PRIMARY KEY (COL1);

TABLE altered.

SQL> EXEC dbms_redefinition.can_redef_table('TEST','TAB_UNPART',1);

PL/SQL PROCEDURE successfully completed.

SQL> @partition_

NAME            OBJECT COLUMN_NAME PARTITIONING_TYPE    STATUS  PARTITION_NAME
--------------- ------ ----------- -------------------- ------- ---------------
TAB_PART        TABLE  COL2        RANGE                VALID   TAB_PART_2013
TAB_PART        TABLE  COL2        RANGE                VALID   TAB_PART_2011
TAB_PART        TABLE  COL2        RANGE                VALID   TAB_PART_2012

SQL> BEGIN
  2  DBMS_REDEFINITION.CAN_REDEF_TABLE('TEST','TAB_UNPART',2);
  3  DBMS_REDEFINITION.START_REDEF_TABLE('TEST','TAB_UNPART','TAB_PART',NULL,2);
  4  DBMS_REDEFINITION.FINISH_REDEF_TABLE('TEST','TAB_UNPART','TAB_PART');
  5  END;
  6  /

PL/SQL PROCEDURE successfully completed.

SQL> @partition_

NAME            OBJECT COLUMN_NAME PARTITIONING_TYPE    STATUS  PARTITION_NAME
--------------- ------ ----------- -------------------- ------- ---------------
TAB_UNPART      TABLE  COL2        RANGE                VALID   TAB_PART_2013
TAB_UNPART      TABLE  COL2        RANGE                VALID   TAB_PART_2011
TAB_UNPART      TABLE  COL2        RANGE                VALID   TAB_PART_2012

SQL> SELECT * FROM tab_unpart partition (TAB_PART_2012);

COL COL2
--- ------------
-1  05-JAN-11

SQL> SELECT * FROM tab_unpart partition (TAB_PART_2011);

no ROWS selected

SQL> SELECT * FROM tab_unpart partition (TAB_PART_2013);

COL COL2
--- ------------
0   05-JAN-12
1   30-DEC-12