1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
#pragma once
#include <library/cpp/json/json_writer.h>
#include <library/cpp/json/json_reader.h>
#include <yql/essentials/minikql/mkql_node.h>
#include <yql/essentials/minikql/computation/mkql_computation_node_holders.h>
#include <library/cpp/enumbitset/enumbitset.h>
namespace NYql {
namespace NCommon {
namespace NJsonCodec {
using namespace NKikimr;
enum EValueConvertPolicy {
CONVERT_POLICY_BEGIN,
NUMBER_AS_STRING = CONVERT_POLICY_BEGIN,
UNSAFE_NUMBER_AS_STRING,
BOOL_AS_STRING,
DISALLOW_NaN,
CONVERT_POLICY_END
};
using TValueConvertPolicy = TEnumBitSet<EValueConvertPolicy, EValueConvertPolicy::CONVERT_POLICY_BEGIN, EValueConvertPolicy::CONVERT_POLICY_END>;
class DefaultPolicy {
public:
static DefaultPolicy& getInstance() {
static DefaultPolicy instance;
return instance;
}
private:
DefaultPolicy() {}
public:
DefaultPolicy(DefaultPolicy &) = delete;
void operator=(const DefaultPolicy &) = delete;
TValueConvertPolicy CloudFunction() const {
return CloudFunctionPolicy;
}
TValueConvertPolicy Export() const {
return ExportPolicy;
}
private:
TValueConvertPolicy CloudFunctionPolicy = TValueConvertPolicy{NUMBER_AS_STRING, BOOL_AS_STRING};
TValueConvertPolicy ExportPolicy = TValueConvertPolicy{DISALLOW_NaN};
};
NJson::TJsonWriterConfig MakeJsonConfig();
void WriteValueToJson(NJson::TJsonWriter& writer, const NUdf::TUnboxedValuePod& value,
NMiniKQL::TType* type, TValueConvertPolicy convertPolicy = {});
NUdf::TUnboxedValue ReadJsonValue(NJson::TJsonValue& json, NMiniKQL::TType* type, const NMiniKQL::THolderFactory& holderFactory);
} // NJsonCodec
} // NCommon
} // NYql
|
