• 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏吧
> java > Java BsonUndefined类的典型用法和代码示例

Java BsonUndefined类的典型用法和代码示例

java 2次浏览

本文整理汇总了Java中org.bson.BsonUndefined类的典型用法代码示例。如果您正苦于以下问题：Java BsonUndefined类的具体用法？Java BsonUndefined怎么用？Java BsonUndefined使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

BsonUndefined类属于org.bson包，在下文中一共展示了BsonUndefined类的19个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getBsonDocument

​ 点赞 3 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
public static BsonDocument getBsonDocument() {
    BsonDocument bsonObj = new BsonDocument().append("testDouble", new BsonDouble(20.777));
    List<BsonDocument> list = new ArrayList<BsonDocument>();
    list.add(bsonObj);
    list.add(bsonObj);
    byte[] bytes = new byte[3];
    bytes[0] = 3;
    bytes[1] = 2;
    bytes[2] = 1;
    BsonDocument bsonDocument = new BsonDocument().append("testDouble", new BsonDouble(20.99))
            .append("testString", new BsonString("testStringV"))
            .append("testArray", new BsonArray(list));
    return new BsonDocument().append("testDouble", new BsonDouble(20.99))
            .append("testString", new BsonString("testStringV"))
            .append("testArray", new BsonArray(list))
            .append("bson_test", bsonDocument)
            .append("testBinary", new BsonBinary(bytes))
            .append("testBsonUndefined", new BsonUndefined())
            .append("testObjectId", new BsonObjectId())
            .append("testStringObjectId", new BsonObjectId())
            .append("testBoolean", new BsonBoolean(true))
            .append("testDate", new BsonDateTime(time))
            .append("testNull", new BsonNull())
            .append("testInt", new BsonInt32(233))
            .append("testLong", new BsonInt64(233332));
}

开发者ID:welkinbai，
项目名称:BsonMapper，
代码行数:27，
代码来源:TestUtil.java

示例2: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(ObjectMapper mapper) {
	SimpleModule module = new SimpleModule();

	addSerializer(module, BsonBoolean.class, (value, gen) -> {
		gen.writeBoolean(value.getValue());
	});

	addSerializer(module, BsonDateTime.class, (value, gen) -> {
		if (Config.USE_TIMESTAMPS) {
			gen.writeString(DataConverterRegistry.convert(String.class, new Date(value.getValue())));
		} else {
			gen.writeNumber(value.getValue());
		}
	});

	addSerializer(module, BsonDouble.class, (value, gen) -> {
		gen.writeNumber(value.getValue());
	});

	addSerializer(module, BsonInt32.class, (value, gen) -> {
		gen.writeNumber(value.getValue());
	});

	addSerializer(module, BsonInt64.class, (value, gen) -> {
		gen.writeNumber(value.getValue());
	});

	addSerializer(module, BsonNull.class, (value, gen) -> {
		gen.writeNull();
	});

	addSerializer(module, BsonRegularExpression.class, (value, gen) -> {
		gen.writeString(value.getPattern());
	});

	addSerializer(module, BsonString.class, (value, gen) -> {
		gen.writeString(value.getValue());
	});

	addSerializer(module, BsonTimestamp.class, (value, gen) -> {
		if (Config.USE_TIMESTAMPS) {
			gen.writeString(DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)));
		} else {
			gen.writeNumber(value.getTime());
		}
	});

	addSerializer(module, BsonUndefined.class, (value, gen) -> {
		gen.writeNull();
	});

	addSerializer(module, Binary.class, (value, gen) -> {
		gen.writeString(BASE64.encode(value.getData()));
	});

	addSerializer(module, Code.class, (value, gen) -> {
		gen.writeString(value.getCode());
	});

	addSerializer(module, Decimal128.class, (value, gen) -> {
		gen.writeNumber(value.bigDecimalValue());
	});

	addSerializer(module, ObjectId.class, (value, gen) -> {
		gen.writeString(value.toHexString());
	});

	addSerializer(module, Symbol.class, (value, gen) -> {
		gen.writeString(value.getSymbol());
	});

	mapper.registerModule(module);
}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:75，
代码来源:JsonJacksonBsonSerializers.java

示例3: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(ExtensibleRepresenter representer) {

	addSerializer(representer, BsonBoolean.class, (value) -> {
		return Boolean.toString(value.getValue());
	});

	addSerializer(representer, BsonDateTime.class, (value) -> {
		if (Config.USE_TIMESTAMPS) {
			return DataConverterRegistry.convert(String.class, new Date(value.getValue()));
		}
		return Long.toString(value.getValue());
	});

	addSerializer(representer, BsonDouble.class, (value) -> {
		return Double.toString(value.getValue());
	});

	addSerializer(representer, BsonInt32.class, (value) -> {
		return Integer.toString(value.getValue());
	});

	addSerializer(representer, BsonInt64.class, (value) -> {
		return Long.toString(value.getValue());
	});

	addSerializer(representer, BsonNull.class, (value) -> {
		return null;
	});

	addSerializer(representer, BsonRegularExpression.class, (value) -> {
		return value.getPattern();
	});

	addSerializer(representer, BsonString.class, (value) -> {
		return value.getValue();
	});

	addSerializer(representer, BsonTimestamp.class, (value) -> {
		if (Config.USE_TIMESTAMPS) {
			return DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L));
		}
		return Integer.toString(value.getTime());
	});

	addSerializer(representer, BsonUndefined.class, (value) -> {
		return null;
	});

	addSerializer(representer, Binary.class, (value) -> {
		return BASE64.encode(value.getData());
	});

	addSerializer(representer, Code.class, (value) -> {
		return value.getCode();
	});

	addSerializer(representer, Decimal128.class, (value) -> {
		return value.bigDecimalValue().toPlainString();
	});

	addSerializer(representer, ObjectId.class, (value) -> {
		return value.toHexString();
	});

	addSerializer(representer, Symbol.class, (value) -> {
		return value.getSymbol();
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:71，
代码来源:YamlSnakeYamlBsonSerializers.java

示例4: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(MapperBuilder builder) {

	addSerializer(builder, BsonBoolean.class, Boolean.class, (value) -> {
		return value.getValue();
	});

	if (Config.USE_TIMESTAMPS) {
		addSerializer(builder, BsonDateTime.class, String.class, (value) -> {
			return DataConverterRegistry.convert(String.class, new Date(value.getValue()));
		});
	} else {
		addSerializer(builder, BsonDateTime.class, Long.class, (value) -> {
			return value.getValue();
		});
	}

	addSerializer(builder, BsonDouble.class, Double.class, (value) -> {
		return value.getValue();
	});

	addSerializer(builder, BsonInt32.class, Integer.class, (value) -> {
		return value.getValue();
	});

	addSerializer(builder, BsonInt64.class, Long.class, (value) -> {
		return value.getValue();
	});

	addSerializer(builder, BsonNull.class, Object.class, (value) -> {

		// Johnzon fails from null values
		return "null";
	});

	addSerializer(builder, BsonRegularExpression.class, String.class, (value) -> {
		return value.getPattern();
	});

	addSerializer(builder, BsonString.class, String.class, (value) -> {
		return value.getValue();
	});

	if (Config.USE_TIMESTAMPS) {
		addSerializer(builder, BsonTimestamp.class, String.class, (value) -> {
			return DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L));
		});
	} else {
		addSerializer(builder, BsonTimestamp.class, Integer.class, (value) -> {
			return value.getTime();
		});
	}

	addSerializer(builder, BsonUndefined.class, String.class, (value) -> {

		// Johnzon fails from null values
		return "null";
	});

	addSerializer(builder, Binary.class, String.class, (value) -> {
		return BASE64.encode(value.getData());
	});

	addSerializer(builder, Code.class, String.class, (value) -> {
		return value.getCode();
	});

	addSerializer(builder, Decimal128.class, BigDecimal.class, (value) -> {
		return value.bigDecimalValue();
	});

	addSerializer(builder, ObjectId.class, String.class, (value) -> {
		return value.toHexString();
	});

	addSerializer(builder, Symbol.class, String.class, (value) -> {
		return value.getSymbol();
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:81，
代码来源:JsonJohnzonBsonSerializers.java

示例5: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(GensonBuilder builder) {

	addSerializer(builder, BsonBoolean.class, (value, writer, ctx) -> {
		writer.writeBoolean(value.getValue());
	});

	addSerializer(builder, BsonDateTime.class, (value, writer, ctx) -> {
		if (Config.USE_TIMESTAMPS) {
			writer.writeString(DataConverterRegistry.convert(String.class, new Date(value.getValue())));
		} else {
			writer.writeNumber(value.getValue());
		}
	});

	addSerializer(builder, BsonDouble.class, (value, writer, ctx) -> {
		writer.writeNumber(value.getValue());
	});

	addSerializer(builder, BsonInt32.class, (value, writer, ctx) -> {
		writer.writeNumber(value.getValue());
	});

	addSerializer(builder, BsonInt64.class, (value, writer, ctx) -> {
		writer.writeNumber(value.getValue());
	});

	addSerializer(builder, BsonNull.class, (value, writer, ctx) -> {
		writer.writeNull();
	});

	addSerializer(builder, BsonRegularExpression.class, (value, writer, ctx) -> {
		writer.writeString(value.getPattern());
	});

	addSerializer(builder, BsonString.class, (value, writer, ctx) -> {
		writer.writeString(value.getValue());
	});

	addSerializer(builder, BsonTimestamp.class, (value, writer, ctx) -> {
		if (Config.USE_TIMESTAMPS) {
			writer.writeString(DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)));
		} else {
			writer.writeNumber(value.getTime());
		}
	});

	addSerializer(builder, BsonUndefined.class, (value, writer, ctx) -> {
		writer.writeNull();
	});

	addSerializer(builder, Binary.class, (value, writer, ctx) -> {
		writer.writeString(BASE64.encode(value.getData()));
	});

	addSerializer(builder, Code.class, (value, writer, ctx) -> {
		writer.writeString(value.getCode());
	});

	addSerializer(builder, Decimal128.class, (value, writer, ctx) -> {
		writer.writeNumber(value.bigDecimalValue());
	});

	addSerializer(builder, ObjectId.class, (value, writer, ctx) -> {
		writer.writeString(value.toHexString());
	});

	addSerializer(builder, Symbol.class, (value, writer, ctx) -> {
		writer.writeString(value.getSymbol());
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:73，
代码来源:JsonGensonBsonSerializers.java

示例6: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(DslJson<Object> dslJson) {

	dslJson.registerWriter(BsonBoolean.class, (writer, value) -> {
		BoolConverter.serialize(value.getValue(), writer);
	});

	dslJson.registerWriter(BsonDateTime.class, (writer, value) -> {
		if (Config.USE_TIMESTAMPS) {
			StringConverter.serialize(DataConverterRegistry.convert(String.class, new Date(value.getValue())),
					writer);
		} else {
			NumberConverter.serialize(value.getValue(), writer);
		}
	});

	dslJson.registerWriter(BsonDouble.class, (writer, value) -> {
		NumberConverter.serialize(value.getValue(), writer);
	});

	dslJson.registerWriter(BsonInt32.class, (writer, value) -> {
		NumberConverter.serialize(value.getValue(), writer);
	});

	dslJson.registerWriter(BsonInt64.class, (writer, value) -> {
		NumberConverter.serialize(value.getValue(), writer);
	});

	dslJson.registerWriter(BsonNull.class, (writer, value) -> {
		writer.writeNull();
	});

	dslJson.registerWriter(BsonRegularExpression.class, (writer, value) -> {
		StringConverter.serializeNullable(value.getPattern(), writer);
	});

	dslJson.registerWriter(BsonString.class, (writer, value) -> {
		StringConverter.serializeNullable(value.getValue(), writer);
	});

	dslJson.registerWriter(BsonTimestamp.class, (writer, value) -> {
		if (Config.USE_TIMESTAMPS) {
			StringConverter.serialize(
					DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)), writer);
		} else {
			NumberConverter.serialize(value.getTime(), writer);
		}
	});

	dslJson.registerWriter(BsonUndefined.class, (writer, value) -> {
		writer.writeNull();
	});

	dslJson.registerWriter(Binary.class, (writer, value) -> {
		StringConverter.serialize(BASE64.encode(value.getData()), writer);
	});

	dslJson.registerWriter(Code.class, (writer, value) -> {
		StringConverter.serializeNullable(value.getCode(), writer);
	});

	dslJson.registerWriter(Decimal128.class, (writer, value) -> {
		NumberConverter.serialize(value.bigDecimalValue(), writer);
	});

	dslJson.registerWriter(ObjectId.class, (writer, value) -> {
		StringConverter.serialize(value.toHexString(), writer);
	});

	dslJson.registerWriter(Symbol.class, (writer, value) -> {
		StringConverter.serializeNullable(value.getSymbol(), writer);
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:75，
代码来源:JsonDSLBsonSerializers.java

示例7: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(MessagePack mapper) {

	addSerializer(mapper, BsonBoolean.class, (packer, value) -> {
		packer.write(value.getValue());
	});

	addSerializer(mapper, BsonDateTime.class, (packer, value) -> {
		packer.write(value.getValue());
	});

	addSerializer(mapper, BsonDouble.class, (packer, value) -> {
		packer.write(value.getValue());
	});

	addSerializer(mapper, BsonInt32.class, (packer, value) -> {
		packer.write(value.getValue());
	});

	addSerializer(mapper, BsonInt64.class, (packer, value) -> {
		packer.write(value.getValue());
	});

	addSerializer(mapper, BsonNull.class, (packer, value) -> {
		packer.writeNil();
	});

	addSerializer(mapper, BsonRegularExpression.class, (packer, value) -> {
		packer.write(value.getPattern());
	});

	addSerializer(mapper, BsonString.class, (packer, value) -> {
		packer.write(value.getValue());
	});

	addSerializer(mapper, BsonTimestamp.class, (packer, value) -> {
		packer.write(value.getTime() * 1000L);
	});

	addSerializer(mapper, BsonUndefined.class, (packer, value) -> {
		packer.writeNil();
	});

	addSerializer(mapper, Binary.class, (packer, value) -> {
		packer.write(BASE64.encode(value.getData()));
	});

	addSerializer(mapper, Code.class, (packer, value) -> {
		packer.write(value.getCode());
	});

	addSerializer(mapper, Decimal128.class, (packer, value) -> {
		packer.write(value.bigDecimalValue());
	});

	addSerializer(mapper, ObjectId.class, (packer, value) -> {
		packer.write(value.toHexString());
	});

	addSerializer(mapper, Symbol.class, (packer, value) -> {
		packer.write(value.getSymbol());
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:65，
代码来源:MsgPackOrgBsonSerializers.java

示例8: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(SerializeConfig config) {

	addSerializer(config, BsonBoolean.class, (value, serializer) -> {
		serializer.write(value.getValue());
	});

	addSerializer(config, BsonDateTime.class, (value, serializer) -> {
		if (Config.USE_TIMESTAMPS) {
			serializer.write(DataConverterRegistry.convert(String.class, new Date(value.getValue())));
		} else {
			serializer.write(value.getValue());
		}
	});

	addSerializer(config, BsonDouble.class, (value, serializer) -> {
		serializer.write(value.getValue());
	});

	addSerializer(config, BsonInt32.class, (value, serializer) -> {
		serializer.write(value.getValue());
	});

	addSerializer(config, BsonInt64.class, (value, serializer) -> {
		serializer.write(value.getValue());
	});

	addSerializer(config, BsonNull.class, (value, serializer) -> {
		serializer.writeNull();
	});

	addSerializer(config, BsonRegularExpression.class, (value, serializer) -> {
		serializer.write(value.getPattern());
	});

	addSerializer(config, BsonString.class, (value, serializer) -> {
		serializer.write(value.getValue());
	});

	addSerializer(config, BsonTimestamp.class, (value, serializer) -> {
		if (Config.USE_TIMESTAMPS) {
			serializer.write(DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)));
		} else {
			serializer.write(value.getTime());
		}
	});

	addSerializer(config, BsonUndefined.class, (value, serializer) -> {
		serializer.writeNull();
	});

	addSerializer(config, Binary.class, (value, serializer) -> {
		serializer.write(BASE64.encode(value.getData()));
	});

	addSerializer(config, Code.class, (value, serializer) -> {
		serializer.write(value.getCode());
	});

	addSerializer(config, Decimal128.class, (value, serializer) -> {
	serializer.write(value.bigDecimalValue());
	});

	addSerializer(config, ObjectId.class, (value, serializer) -> {
		serializer.write(value.toHexString());
	});

	addSerializer(config, Symbol.class, (value, serializer) -> {
		serializer.write(value.getSymbol());
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:73，
代码来源:JsonFastBsonSerializers.java

示例9: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(JsonSerializer serializer) {

	addSerializer(serializer, BsonBoolean.class, (value, ctx) -> {
		ctx.write(Boolean.toString(value.getValue()));
	});

	addSerializer(serializer, BsonDateTime.class, (value, ctx) -> {
		if (Config.USE_TIMESTAMPS) {
			ctx.writeString(DataConverterRegistry.convert(String.class, new Date(value.getValue())));
		} else {
			ctx.writeNumber(value.getValue());
		}
	});

	addSerializer(serializer, BsonDouble.class, (value, ctx) -> {
		ctx.writeNumber(value.getValue());
	});

	addSerializer(serializer, BsonInt32.class, (value, ctx) -> {
		ctx.writeNumber(value.getValue());
	});

	addSerializer(serializer, BsonInt64.class, (value, ctx) -> {
		ctx.writeNumber(value.getValue());
	});

	addSerializer(serializer, BsonNull.class, (value, ctx) -> {
		ctx.write("null");
	});

	addSerializer(serializer, BsonRegularExpression.class, (value, ctx) -> {
		ctx.writeString(value.getPattern());
	});

	addSerializer(serializer, BsonString.class, (value, ctx) -> {
		ctx.writeString(value.getValue());
	});
	
	addSerializer(serializer, BsonTimestamp.class, (value, ctx) -> {
		if (Config.USE_TIMESTAMPS) {
			ctx.writeString(
					DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)));
		} else {
			ctx.writeNumber(value.getTime());
		}
	});

	addSerializer(serializer, BsonUndefined.class, (value, ctx) -> {
		ctx.write("null");
	});

	addSerializer(serializer, Binary.class, (value, ctx) -> {
		ctx.writeString(BASE64.encode(value.getData()));
	});

	addSerializer(serializer, Code.class, (value, ctx) -> {
		ctx.writeString(value.getCode());
	});

	addSerializer(serializer, Decimal128.class, (value, ctx) -> {
		ctx.writeNumber(value.bigDecimalValue());
	});

	addSerializer(serializer, ObjectId.class, (value, ctx) -> {
		ctx.writeString(value.toHexString());
	});

	addSerializer(serializer, Symbol.class, (value, ctx) -> {
		ctx.writeString(value.getSymbol());
	});
}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:73，
代码来源:JsonJoddBsonSerializers.java

示例10: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(TypeTransformerMap map) {

	addSerializer(map, BsonBoolean.class, (value, ctx) -> {
		ctx.write(Boolean.toString(value.getValue()));
	});

	addSerializer(map, BsonDateTime.class, (value, ctx) -> {
		if (Config.USE_TIMESTAMPS) {
			ctx.writeQuoted(DataConverterRegistry.convert(String.class, new Date(value.getValue())));
		} else {
			ctx.write(Long.toString(value.getValue()));
		}
	});

	addSerializer(map, BsonDouble.class, (value, ctx) -> {
		ctx.write(Double.toString(value.getValue()));
	});

	addSerializer(map, BsonInt32.class, (value, ctx) -> {
		ctx.write(Integer.toString(value.getValue()));
	});

	addSerializer(map, BsonInt64.class, (value, ctx) -> {
		ctx.write(Long.toString(value.getValue()));
	});

	addSerializer(map, BsonNull.class, (value, ctx) -> {
		ctx.write("null");
	});

	addSerializer(map, BsonRegularExpression.class, (value, ctx) -> {
		ctx.writeQuoted(value.getPattern());
	});

	addSerializer(map, BsonString.class, (value, ctx) -> {
		ctx.writeQuoted(value.getValue());
	});

	addSerializer(map, BsonTimestamp.class, (value, ctx) -> {
		if (Config.USE_TIMESTAMPS) {
			ctx.writeQuoted(DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)));
		} else {
			ctx.write(Integer.toString(value.getTime()));
		}
	});

	addSerializer(map, BsonUndefined.class, (value, ctx) -> {
		ctx.write("null");
	});

	addSerializer(map, Binary.class, (value, ctx) -> {
		ctx.writeQuoted(BASE64.encode(value.getData()));
	});

	addSerializer(map, Code.class, (value, ctx) -> {
		ctx.writeQuoted(value.getCode());
	});

	addSerializer(map, Decimal128.class, (value, ctx) -> {
		ctx.write(value.bigDecimalValue().toPlainString());
	});

	addSerializer(map, ObjectId.class, (value, ctx) -> {
		ctx.writeQuoted(value.toHexString());
	});

	addSerializer(map, Symbol.class, (value, ctx) -> {
		ctx.writeQuoted(value.getSymbol());
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:73，
代码来源:JsonFlexBsonSerializers.java

示例11: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(HashMap<Class<?>, Function<Object, Object>> converters) {
	
	addSerializer(converters, BsonBoolean.class, (value) -> {
		return value.getValue();
	});

	addSerializer(converters, BsonDateTime.class, (value) -> {
		return new Date(value.getValue());
	});

	addSerializer(converters, BsonDouble.class, (value) -> {
		return value.getValue();
	});

	addSerializer(converters, BsonInt32.class, (value) -> {
		return value.getValue();
	});

	addSerializer(converters, BsonInt64.class, (value) -> {
		return value.getValue();
	});

	addSerializer(converters, BsonNull.class, (value) -> {
		return null;
	});

	addSerializer(converters, BsonRegularExpression.class, (value) -> {
		return value.getPattern();
	});

	addSerializer(converters, BsonString.class, (value) -> {
		return value.getValue();
	});

	addSerializer(converters, BsonTimestamp.class, (value) -> {
		return new Date(value.getTime() * 1000L);
	});

	addSerializer(converters, BsonUndefined.class, (value) -> {
		return null;
	});

	addSerializer(converters, Binary.class, (value) -> {
		return value.getData();
	});

	addSerializer(converters, Code.class, (value) -> {
		return value.getCode();
	});

	addSerializer(converters, Decimal128.class, (value) -> {
		return value.bigDecimalValue();
	});

	addSerializer(converters, ObjectId.class, (value) -> {
		return value.toHexString();
	});

	addSerializer(converters, Symbol.class, (value) -> {
		return value.getSymbol();
	});
	
}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:65，
代码来源:IonIonBsonSerializers.java

示例12: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(GsonBuilder builder) {

	addSerializer(builder, BsonBoolean.class, (value) -> {
		return new JsonPrimitive(value.getValue());
	});

	addSerializer(builder, BsonDateTime.class, (value) -> {
		if (Config.USE_TIMESTAMPS) {
			return new JsonPrimitive(DataConverterRegistry.convert(String.class, new Date(value.getValue())));
		} else {
			return new JsonPrimitive(value.getValue());
		}
	});

	addSerializer(builder, BsonDouble.class, (value) -> {
		return new JsonPrimitive(value.getValue());
	});

	addSerializer(builder, BsonInt32.class, (value) -> {
		return new JsonPrimitive(value.getValue());
	});

	addSerializer(builder, BsonInt64.class, (value) -> {
		return new JsonPrimitive(value.getValue());
	});

	addSerializer(builder, BsonNull.class, (value) -> {
		return JsonNull.INSTANCE;
	});

	addSerializer(builder, BsonRegularExpression.class, (value) -> {
		return new JsonPrimitive(value.getPattern());
	});

	addSerializer(builder, BsonString.class, (value) -> {
		return new JsonPrimitive(value.getValue());
	});

	addSerializer(builder, BsonTimestamp.class, (value) -> {
		if (Config.USE_TIMESTAMPS) {
			return new JsonPrimitive(
					DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L)));
		} else {
			return new JsonPrimitive(value.getTime());
		}
	});

	addSerializer(builder, BsonUndefined.class, (value) -> {
		return JsonNull.INSTANCE;
	});

	addSerializer(builder, Binary.class, (value) -> {
		return new JsonPrimitive(BASE64.encode(value.getData()));
	});

	addSerializer(builder, Code.class, (value) -> {
		return new JsonPrimitive(value.getCode());
	});

	addSerializer(builder, Decimal128.class, (value) -> {
		return new JsonPrimitive(value.bigDecimalValue());
	});

	addSerializer(builder, ObjectId.class, (value) -> {
		return new JsonPrimitive(value.toHexString());
	});

	addSerializer(builder, Symbol.class, (value) -> {
		return new JsonPrimitive(value.getSymbol());
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:74，
代码来源:JsonGsonBsonSerializers.java

示例13: accept

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public void accept(XStream mapper) {

	addSerializer(mapper, BsonBoolean.class, (value) -> {
		return Boolean.toString(value.getValue());
	});

	addSerializer(mapper, BsonDateTime.class, (value) -> {
		if (Config.USE_TIMESTAMPS) {
			return DataConverterRegistry.convert(String.class, new Date(value.getValue()));
		}
		return Long.toString(value.getValue());
	});

	addSerializer(mapper, BsonDouble.class, (value) -> {
		return Double.toString(value.getValue());
	});

	addSerializer(mapper, BsonInt32.class, (value) -> {
		return Integer.toString(value.getValue());
	});

	addSerializer(mapper, BsonInt64.class, (value) -> {
		return Long.toString(value.getValue());
	});

	addSerializer(mapper, BsonNull.class, (value) -> {
		return "null";
	});

	addSerializer(mapper, BsonRegularExpression.class, (value) -> {
		return value.getPattern();
	});

	addSerializer(mapper, BsonString.class, (value) -> {
		return value.getValue();
	});

	addSerializer(mapper, BsonTimestamp.class, (value) -> {
		if (Config.USE_TIMESTAMPS) {
			return DataConverterRegistry.convert(String.class, new Date(value.getTime() * 1000L));
		}
		return Integer.toString(value.getTime());
	});

	addSerializer(mapper, BsonUndefined.class, (value) -> {
		return "null";
	});

	addSerializer(mapper, Binary.class, (value) -> {
		return BASE64.encode(value.getData());
	});

	addSerializer(mapper, Code.class, (value) -> {
		return value.getCode();
	});

	addSerializer(mapper, Decimal128.class, (value) -> {
		return value.bigDecimalValue().toPlainString();
	});

	addSerializer(mapper, ObjectId.class, (value) -> {
		return value.toHexString();
	});

	addSerializer(mapper, Symbol.class, (value) -> {
		return value.getSymbol();
	});

}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:71，
代码来源:XmlXStreamBsonSerializers.java

示例14: testMongoTypes

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Test
public void testMongoTypes() throws Exception {

	// JSON-Simple and JsonUtil aren't extendable APIs
	String writerClass = TreeWriterRegistry.getWriter(TreeWriterRegistry.JSON).getClass().toString();
	boolean unsupportedAPI = writerClass.contains("Simple") || writerClass.contains("JsonUtil");
	if (unsupportedAPI) {
		return;
	}

	Document doc = new Document();
	doc.put("BsonBoolean", new BsonBoolean(true));
	long time = System.currentTimeMillis();
	doc.put("BsonDateTime", new BsonDateTime(time));
	doc.put("BsonDouble", new BsonDouble(123.456));
	doc.put("BsonInt32", new BsonInt32(123));
	doc.put("BsonInt64", new BsonInt64(123456));
	doc.put("BsonNull", new BsonNull());
	doc.put("BsonRegularExpression", new BsonRegularExpression("abc"));
	doc.put("BsonString", new BsonString("abcdefgh"));
	doc.put("BsonTimestamp", new BsonTimestamp(12, 23));
	doc.put("BsonUndefined", new BsonUndefined());
	doc.put("Binary", new Binary("abcdefgh".getBytes()));
	doc.put("Code", new Code("var a = 5;"));
	doc.put("Decimal128", new Decimal128(123456789));
	ObjectId objectID = new ObjectId();
	doc.put("ObjectId", objectID);
	doc.put("Symbol", new Symbol("s"));

	Tree t = new Tree(doc, null);
	String json = t.toString();

	System.out.println("-------------------- BSON --------------------");
	System.out.println("Output of " + writerClass + " serializer (MongoDB types):");
	System.out.println(json);

	t = new Tree(json);

	assertTrue(t.get("BsonBoolean", false));

	Date date = t.get("BsonDateTime", new Date());
	assertEquals(time / 1000L, date.getTime() / 1000L);

	assertEquals(123.456, t.get("BsonDouble", 1d));
	assertEquals(123, t.get("BsonInt32", 1));
	assertEquals(123456L, t.get("BsonInt64", 1L));
	assertNull(t.get("BsonNull", "?"));
	assertEquals("abc", t.get("BsonRegularExpression", "?"));
	assertEquals("abcdefgh", t.get("BsonString", "?"));

	// String or Number
	date = t.get("BsonTimestamp", new Date());
	assertEquals(12000L, date.getTime());

	assertNull(t.get("BsonUndefined", "?"));
	assertEquals("abcdefgh", new String(t.get("Binary", "?".getBytes())));
	assertEquals("var a = 5;", t.get("Code", "?"));
	assertEquals(123456789L, t.get("Decimal128", 1L));
	assertEquals(objectID.toHexString(), t.get("ObjectId", "?"));
	assertEquals("s", t.get("Symbol", "?"));
}

开发者ID:berkesa，
项目名称:datatree-adapters，
代码行数:62，
代码来源:ExtendedTreeTest.java

示例15: testMongoTypes

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Test
public void testMongoTypes() throws Exception {
	Document doc = new Document();
	doc.put("BsonBoolean", new BsonBoolean(true));
	doc.put("BsonDateTime", new BsonDateTime(12345));
	doc.put("BsonDouble", new BsonDouble(123.456));
	doc.put("BsonInt32", new BsonInt32(123));
	doc.put("BsonInt64", new BsonInt64(123456));
	doc.put("BsonNull", new BsonNull());
	doc.put("BsonRegularExpression", new BsonRegularExpression("abc"));
	doc.put("BsonString", new BsonString("abcdefgh"));
	doc.put("BsonTimestamp", new BsonTimestamp(12, 23));
	doc.put("BsonUndefined", new BsonUndefined());
	doc.put("Binary", new Binary("abcdefgh".getBytes()));
	doc.put("Code", new Code("var a = 5;"));
	doc.put("Decimal128", new Decimal128(123456789));
	doc.put("ObjectId", new ObjectId());
	doc.put("Symbol", new Symbol("s"));
	
	Document map = new Document();
	map.put("a", "b");
	map.put("c", 5);
	doc.put("map", map);
	
	ArrayList<Object> list = new ArrayList<>();
	list.add("c");
	list.add("b");
	list.add("a");
	doc.put("list", list);
	
	Tree t = new Tree(doc, null);
	String json = t.toString();
	
	String writerClass = TreeWriterRegistry.getWriter(TreeWriterRegistry.JSON).getClass().toString();
	System.out.println("--------------------------------------------------------------");
	System.out.println("Output of " + writerClass + " serializer:");
	System.out.println(json);
	
	Tree t2 = new Tree(json);
	
	assertEquals(true, t2.get("BsonBoolean", false));
	// assertEquals(12345, t2.get("BsonDateTime", -1));
	assertEquals(123.456, t2.get("BsonDouble", 1d));
	assertEquals(123, t2.get("BsonInt32", 345));
	assertEquals(123456, t2.get("BsonInt64", 1));
	assertNull(t2.get("BsonNull", "X"));
	assertEquals("abc", t2.get("BsonRegularExpression", "xcf"));
	assertEquals("abcdefgh", t2.get("BsonString", "fsdfasdf"));
	// doc.put("BsonTimestamp", new BsonTimestamp(12, 23));
	// doc.put("BsonUndefined", new BsonUndefined());
	// doc.put("Binary", new Binary("abcdefgh".getBytes()));
	// doc.put("Code", new Code("var a = 5;"));
	// doc.put("Decimal128", new Decimal128(123456789));
	// doc.put("ObjectId", new ObjectId());
	// doc.put("Symbol", new Symbol("s"));
}

开发者ID:berkesa，
项目名称:datatree，
代码行数:57，
代码来源:TreeTest.java

示例16: decode

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public BsonUndefined decode(BsonValue bsonValue) {
    throw new BsonMapperConverterException("BsonUndefined type is not support");
}

开发者ID:welkinbai，
项目名称:BsonMapper，
代码行数:5，
代码来源:BsonUndefinedConverter.java

示例17: encode

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Override
public BsonUndefined encode(BsonUndefined object) {
    throw new BsonMapperConverterException("BsonUndefined type is not support");
}

开发者ID:welkinbai，
项目名称:BsonMapper，
代码行数:5，
代码来源:BsonUndefinedConverter.java

示例18: decode

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
@Test
public void decode() throws Exception {
    BsonDocument bsonObj = new BsonDocument().append("testDouble", new BsonDouble(20.777));
    List<BsonDocument> list = new ArrayList<BsonDocument>();
    list.add(bsonObj);
    list.add(bsonObj);
    List<BsonArray> arrayList = new ArrayList<BsonArray>();
    arrayList.add(new BsonArray(list));
    arrayList.add(new BsonArray(list));
    byte[] bytes = new byte[3];
    bytes[0] = 3;
    bytes[1] = 2;
    bytes[2] = 1;
    BsonDocument bsonDocument = new BsonDocument().append("testDouble", new BsonDouble(20.99))
            .append("testString", new BsonString("testStringV"))
            .append("testArray", new BsonArray(list));
    BsonDocument bsonDocument1 = new BsonDocument().append("testDouble", new BsonDouble(20.99))
            .append("testString", new BsonString("testStringV"))
            .append("testArray", new BsonArray(list))
            .append("bson_test", bsonDocument)
            .append("testBinary", new BsonBinary(bytes))
            .append("testBsonUndefined", new BsonUndefined())
            .append("testObjectId", new BsonObjectId())
            .append("testStringObjectId", new BsonObjectId())
            .append("testBoolean", new BsonBoolean(true))
            .append("testDate", new BsonDateTime(new Date().getTime()))
            .append("testNull", new BsonNull())
            .append("testInt", new BsonInt32(233))
            .append("testLong", new BsonInt64(233332));
    BsonTest bsonTest = BsonDocumentConverter.getInstance().decode(bsonDocument1, BsonTest.class, BsonMapperConfig.DEFALUT);
    System.out.println(bsonTest.getTestDouble());
    System.out.println(bsonTest.getTestString());
    System.out.println(bsonTest.getTestArray());
    System.out.println(Arrays.toString(bsonTest.getTestBinary().getData()));
    System.out.println(bsonTest.getTestObjectId());
    System.out.println(bsonTest.getTestStringObjectId());
    System.out.println(bsonTest.isTestBoolean());
    System.out.println(bsonTest.getTestDate());
    System.out.println(bsonTest.getTestNull());
    System.out.println(bsonTest.getTestInt());
    System.out.println(bsonTest.getTestLong());
    System.out.println(bsonTest);
}

开发者ID:welkinbai，
项目名称:BsonMapper，
代码行数:44，
代码来源:BsonDocumentConverterTest.java

示例19: convertToKettleValue

​ 点赞 2 ​ 

import org.bson.BsonUndefined; //导入依赖的package包/类
/**
 * Convert a mongo record object to a Kettle field value (for the field defined by this path)
 * 
 * @param mongoObject
 *          the record to convert
 * @return the kettle field value
 * @throws KettleException
 *           if a problem occurs
 */
public Object convertToKettleValue( BasicDBObject mongoObject ) throws KettleException {

  if ( mongoObject == null ) {
    return null;
  }

  if ( m_tempParts.size() == 0 ) {
    throw new KettleException( BaseMessages.getString( PKG, "MongoDbInput.ErrorMessage.MalformedPathRecord" ) ); //$NON-NLS-1$
  }

  String part = m_tempParts.remove( 0 );

  if ( part.charAt( 0 ) == '[' ) {
    // we're not expecting an array at this point - this document does not
    // contain our field
    return null;
  }

  if ( part.indexOf( '[' ) > 0 ) {
    String arrayPart = part.substring( part.indexOf( '[' ) );
    part = part.substring( 0, part.indexOf( '[' ) );

    // put the array section back into location zero
    m_tempParts.add( 0, arrayPart );
  }

  // part is a named field of this record
  Object fieldValue = mongoObject.get( part );
  if ( fieldValue == null || fieldValue.getClass().equals( BsonUndefined.class ) ) {
    return null;
  }

  // what have we got
  if ( m_tempParts.size() == 0 ) {
    // we're expecting a leaf primitive - lets see if that's what we have
    // here...
    return getKettleValue( fieldValue );
  }

  if ( fieldValue instanceof BasicDBObject ) {
    return convertToKettleValue( ( (BasicDBObject) fieldValue ) );
  }

  if ( fieldValue instanceof BasicDBList ) {
    return convertToKettleValue( ( (BasicDBList) fieldValue ) );
  }

  // must mean we have a primitive here, but we're expecting to process more
  // path so this doesn't match us - return null
  return null;
}

开发者ID:pentaho，
项目名称:pentaho-mongodb-plugin，
代码行数:61，
代码来源:MongoField.java

版权声明：本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系管理员进行删除。
喜欢 (0)