修改时间类型精度

client/client_query_response.go

@@ -25,7 +25,7 @@ func FormEventInfo(info *response.EventInfo) *EventInfo {
 		Operation:  info.Operation,
 		Value:      info.Value,
 		CreatorID:  info.CreatorID,
-		CreateTime: time.Unix(info.CreateTimeUnix, 0).Local(),
+		CreateTime: time.Unix(0, info.CreateTimeUnix*1000).Local(),
 	}
 }
 

client/table_row.go

@@ -251,7 +251,7 @@ func (tableRow *TableRow) ToDPSTableRow() (*request.TableRow, error) {
 		switch valueType.Name() {
 		case "Time":
 			timeObj := value.(time.Time)
-			typedValue.TypedValue = &request.ColumnValue_Uint64Value{Uint64Value: uint64(timeObj.Unix())}
+			typedValue.TypedValue = &request.ColumnValue_Uint64Value{Uint64Value: uint64(timeObj.UnixMicro())}
 		case "string":
 			typedValue.TypedValue = &request.ColumnValue_StringValue{StringValue: value.(string)}
 		case "bool":
@@ -278,7 +278,7 @@ func (tableRow *TableRow) FromDSPInfoData(infoData *response.InfoData) error {
 		typeStr := column.Value.Type
 
 		if typeStr == "Time" {
-			timeObj := time.Unix(int64(column.Value.GetUint64Value()), 0)
+			timeObj := time.Unix(0, int64(column.Value.GetUint64Value()*1000))
 			tableRow.row[column.Name] = timeObj
 		} else if typeStr == "string" {
 			tableRow.row[column.Name] = column.Value.GetStringValue()

test/instance/instance_test.go

@@ -53,10 +53,10 @@ func TestTransaction(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var count int64
 	resultTableRow := client.NewTableRow()
@@ -97,7 +97,7 @@ func TestTransaction(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.UpdateTx(&client.UpdateRequest{
@@ -126,7 +126,7 @@ func TestTransaction(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.UpdateTx(&client.UpdateRequest{
@@ -210,16 +210,16 @@ func TestTransactionBatch(t *testing.T) {
 	id1 := simpleUUID()
 	name1 := simpleUUID()
 	now1 := time.Now().Local()
-	tableNum1 := rand.New(rand.NewSource(now1.Unix())).Intn(10)
+	tableNum1 := rand.New(rand.NewSource(now1.UnixMicro())).Intn(10)
 
 	id2 := simpleUUID()
 	name2 := simpleUUID()
 	now2 := time.Now().Local()
-	tableNum2 := rand.New(rand.NewSource(now2.Unix())).Intn(10)
+	tableNum2 := rand.New(rand.NewSource(now2.UnixMicro())).Intn(10)
 
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(newNow.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(newNow.UnixMicro())).Intn(10)
 
 	var count int64
 	resultTableRow := client.NewTableRow()
@@ -270,7 +270,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id1, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name1, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now1.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now1.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum1, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		queryByKeys(&client.QueryByKeysRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -279,7 +279,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id2, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name2, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now2.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now2.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum2, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.UpdateWhereTx(&client.UpdateWhereRequest{
@@ -308,7 +308,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id1, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		queryByKeys(&client.QueryByKeysRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -317,7 +317,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id2, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.DeleteWhereTx(&client.DeleteWhereRequest{
@@ -358,7 +358,7 @@ func TestInsert(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 	var exist bool
@@ -390,7 +390,7 @@ func TestInsert(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		checkExistWhere(&client.CountWhereRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -418,12 +418,12 @@ func TestInsertBatch(t *testing.T) {
 	id1 := simpleUUID()
 	name1 := simpleUUID()
 	now1 := time.Now().Local()
-	tableNum1 := rand.New(rand.NewSource(now1.Unix())).Intn(10)
+	tableNum1 := rand.New(rand.NewSource(now1.UnixMicro())).Intn(10)
 
 	id2 := simpleUUID()
 	name2 := simpleUUID()
 	now2 := time.Now().Local()
-	tableNum2 := rand.New(rand.NewSource(now2.Unix())).Intn(10)
+	tableNum2 := rand.New(rand.NewSource(now2.UnixMicro())).Intn(10)
 
 	resultTableRows := make([]client.TableRow, 0)
 	var totalCount int64
@@ -471,7 +471,7 @@ func TestInsertBatch(t *testing.T) {
 		assertEqual(1, int(totalCount), "总数不一致").
 		assertEqual(id1, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name1, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now1.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now1.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum1, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致").
 		commonQuery(&client.CommonQueryRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -486,7 +486,7 @@ func TestInsertBatch(t *testing.T) {
 		assertEqual(1, int(totalCount), "总数不一致").
 		assertEqual(id2, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name2, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now2.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now2.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum2, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致").
 		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -500,7 +500,7 @@ func TestInsertBatch(t *testing.T) {
 		}, &resultTableRows).
 		assertEqual(id1, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name1, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now1.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now1.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum1, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致").
 		commonQueryOnly(&client.CommonQueryRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -514,7 +514,7 @@ func TestInsertBatch(t *testing.T) {
 		}, &resultTableRows).
 		assertEqual(id2, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name2, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now2.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now2.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum2, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -527,10 +527,10 @@ func TestUpdate(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -572,7 +572,7 @@ func TestUpdate(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -585,10 +585,10 @@ func TestUpdateWhere(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -631,7 +631,7 @@ func TestUpdateWhere(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -644,7 +644,7 @@ func TestDelete(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var count int64
 
@@ -691,7 +691,7 @@ func TestDeleteWhere(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var count int64
 
@@ -739,7 +739,7 @@ func TestReply(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -776,7 +776,7 @@ func TestReply(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -793,10 +793,10 @@ func TestEventQuery(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var exist bool
 	var totalCount int64

test/v1/v1_test.go

@@ -55,10 +55,10 @@ func TestTransaction(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var count int64
 	resultTableRow := client.NewTableRow()
@@ -101,7 +101,7 @@ func TestTransaction(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.UpdateTx(&client.UpdateRequest{
@@ -130,7 +130,7 @@ func TestTransaction(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.UpdateTx(&client.UpdateRequest{
@@ -214,16 +214,16 @@ func TestTransactionBatch(t *testing.T) {
 	id1 := simpleUUID()
 	name1 := simpleUUID()
 	now1 := time.Now().Local()
-	tableNum1 := rand.New(rand.NewSource(now1.Unix())).Intn(10)
+	tableNum1 := rand.New(rand.NewSource(now1.UnixMicro())).Intn(10)
 
 	id2 := simpleUUID()
 	name2 := simpleUUID()
 	now2 := time.Now().Local()
-	tableNum2 := rand.New(rand.NewSource(now2.Unix())).Intn(10)
+	tableNum2 := rand.New(rand.NewSource(now2.UnixMicro())).Intn(10)
 
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(newNow.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(newNow.UnixMicro())).Intn(10)
 
 	var count int64
 	resultTableRow := client.NewTableRow()
@@ -276,7 +276,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id1, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name1, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now1.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now1.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum1, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		queryByKeys(&client.QueryByKeysRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -285,7 +285,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id2, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name2, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now2.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now2.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum2, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.UpdateWhereTx(&client.UpdateWhereRequest{
@@ -314,7 +314,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id1, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		queryByKeys(&client.QueryByKeysRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -323,7 +323,7 @@ func TestTransactionBatch(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id2, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
 		transaction(func(tx client.Transaction) error {
 			statement, err := tx.DeleteWhereTx(&client.DeleteWhereRequest{
@@ -363,7 +363,7 @@ func TestInsert(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -396,7 +396,7 @@ func TestInsert(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -409,12 +409,12 @@ func TestInsertBatch(t *testing.T) {
 	id1 := simpleUUID()
 	name1 := simpleUUID()
 	now1 := time.Now().Local()
-	tableNum1 := rand.New(rand.NewSource(now1.Unix())).Intn(10)
+	tableNum1 := rand.New(rand.NewSource(now1.UnixMicro())).Intn(10)
 
 	id2 := simpleUUID()
 	name2 := simpleUUID()
 	now2 := time.Now().Local()
-	tableNum2 := rand.New(rand.NewSource(now2.Unix())).Intn(10)
+	tableNum2 := rand.New(rand.NewSource(now2.UnixMicro())).Intn(10)
 
 	resultTableRows := make([]client.TableRow, 0)
 	var totalCount int64
@@ -464,7 +464,7 @@ func TestInsertBatch(t *testing.T) {
 		assertEqual(1, int(totalCount), "总数不一致").
 		assertEqual(id1, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name1, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now1.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now1.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum1, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致").
 		commonQuery(&client.CommonQueryRequest{
 			Table: tablePrefix + "_snaps_v1",
@@ -478,7 +478,7 @@ func TestInsertBatch(t *testing.T) {
 		assertEqual(1, int(totalCount), "总数不一致").
 		assertEqual(id2, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name2, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now2.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now2.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum2, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致").
 		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -492,7 +492,7 @@ func TestInsertBatch(t *testing.T) {
 		}, &resultTableRows).
 		assertEqual(id1, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name1, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now1.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now1.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum1, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致").
 		commonQueryOnly(&client.CommonQueryRequest{
 			TablePrefixWithSchema: tablePrefix,
@@ -506,7 +506,7 @@ func TestInsertBatch(t *testing.T) {
 		}, &resultTableRows).
 		assertEqual(id2, resultTableRows[0].ColumnValueString("id"), "ID不一致").
 		assertEqual(name2, resultTableRows[0].ColumnValueString("name"), "名称不一致").
-		assertEqual(now2.Unix(), resultTableRows[0].ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now2.UnixMicro(), resultTableRows[0].ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum2, resultTableRows[0].ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -519,10 +519,10 @@ func TestUpdate(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -566,7 +566,7 @@ func TestUpdate(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -579,10 +579,10 @@ func TestUpdateWhere(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(newNow.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(newNow.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -627,7 +627,7 @@ func TestUpdateWhere(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(newNow.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -640,7 +640,7 @@ func TestDelete(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var count int64
 
@@ -689,7 +689,7 @@ func TestDeleteWhere(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var count int64
 
@@ -739,7 +739,7 @@ func TestReply(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	resultTableRow := client.NewTableRow()
 
@@ -778,7 +778,7 @@ func TestReply(t *testing.T) {
 		}, resultTableRow).
 		assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
 		assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
-		assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
+		assertEqual(now.UnixMicro(), resultTableRow.ColumnValueTime("time").UnixMicro(), "时间不一致").
 		assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
 }
 
@@ -795,10 +795,10 @@ func TestEventQuery(t *testing.T) {
 	id := simpleUUID()
 	name := simpleUUID()
 	now := time.Now().Local()
-	tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	tableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 	newName := simpleUUID()
 	newNow := time.Now().Local()
-	newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
+	newTableNum := rand.New(rand.NewSource(now.UnixMicro())).Intn(10)
 
 	var totalCount int64
 	eventInfos := make([]client.EventInfo, 0)