#pragma once
#include
#include
#include
#include
#include
#include
#include
namespace DB
{
class Context;
using ContextPtr = std::shared_ptr;
}
class DateLUTImpl;
/// This class provides lazy initialization and lookup of singleton DateLUTImpl objects for a given timezone.
class DateLUT : private boost::noncopyable
{
public:
/// Return DateLUTImpl instance for session timezone.
/// session_timezone is a session-level setting.
/// If setting is not set, returns the server timezone.
static const DateLUTImpl & instance();
static ALWAYS_INLINE const DateLUTImpl & instance(const std::string & time_zone)
{
if (time_zone.empty())
return instance();
const auto & date_lut = getInstance();
return date_lut.getImplementation(time_zone);
}
/// Return singleton DateLUTImpl for the server time zone.
/// It may be set using 'timezone' server setting.
static ALWAYS_INLINE const DateLUTImpl & serverTimezoneInstance()
{
const auto & date_lut = getInstance();
return *date_lut.default_impl.load(std::memory_order_acquire);
}
static void setDefaultTimezone(const std::string & time_zone)
{
auto & date_lut = getInstance();
const auto & impl = date_lut.getImplementation(time_zone);
date_lut.default_impl.store(&impl, std::memory_order_release);
}
protected:
DateLUT();
private:
static DateLUT & getInstance();
static std::string extractTimezoneFromContext(DB::ContextPtr query_context);
const DateLUTImpl & getImplementation(const std::string & time_zone) const;
using DateLUTImplPtr = std::unique_ptr;
/// Time zone name -> implementation.
mutable std::unordered_map impls;
mutable std::mutex mutex;
std::atomic default_impl;
};
inline UInt64 timeInMilliseconds(std::chrono::time_point timepoint)
{
return std::chrono::duration_cast(timepoint.time_since_epoch()).count();
}
inline UInt64 timeInMicroseconds(std::chrono::time_point timepoint)
{
return std::chrono::duration_cast(timepoint.time_since_epoch()).count();
}
inline UInt64 timeInSeconds(std::chrono::time_point timepoint)
{
return std::chrono::duration_cast(timepoint.time_since_epoch()).count();
}
inline UInt64 timeInNanoseconds(std::chrono::time_point timepoint)
{
return std::chrono::duration_cast(timepoint.time_since_epoch()).count();
}