1

include/db/sqler.h

@@ -81,7 +81,7 @@ namespace ylib
 		/// </summary>
 		select& where_not_between(const std::string& name, const std::any& begin, const std::any& end);
 		/// <summary>
-		/// 条件[自定义]
+		/// 条件[自定义],需要自行最前面拼接 AND 或 OR，如："AND (a = b)"
 		/// </summary>
 		select& where(const std::string& expression);
 		/// <summary>
@@ -207,7 +207,7 @@ namespace ylib
 		/// </summary>
 		update& where_not_between(const std::string& name, const std::any& begin, const std::any& end);
 		/// <summary>
-		/// 条件[自定义]
+		/// 条件[自定义],需要自行最前面拼接 AND 或 OR，如："AND (a = b)"
 		/// </summary>
 		update& where(const std::string& expression);
 		/// <summary>
@@ -332,7 +332,7 @@ namespace ylib
 		/// </summary>
 		delete_& where_not_between(const std::string& name, const std::any& begin, const std::any& end);
 		/// <summary>
-		/// 条件[自定义]
+		/// 条件[自定义],需要自行最前面拼接 AND 或 OR，如："AND (a = b)"
 		/// </summary>
 		delete_& where(const std::string& expression);
 		/// <summary>

include/net/http_reqpack.h

@@ -91,6 +91,11 @@ namespace ylib
                 /// <returns></returns>
                 const std::shared_ptr<network::http::websocket_message>& ws_msg() { return m_ws_msg; }
 
+                /// <summary>
+                /// 创建时间
+                /// </summary>
+                /// <returns></returns>
+                int64 create_time() { return m_create_time; }
 
                 /// <summary>
                 /// 设置为关闭连接包
@@ -122,7 +127,9 @@ namespace ylib
                 network::http::message_type m_msg_type = HTTP_SERVER_MESSAGE_TYPE_NORMAL;
                 // 是否为关闭连接包
                 bool m_is_close = false;
-                
+
+                // 创建时间
+                int64 m_create_time = 0;
             };
         }
     }

include/util/json.h

@@ -286,6 +286,22 @@ namespace ylib
         {
             return static_cast<const json&>(base::at(idx));
         }
+        json& operator[](int idx)
+        {
+            return static_cast<json&>(base::operator[](idx));
+        }
+        const json& operator[](int idx) const
+        {
+            return static_cast<const json&>(base::at(idx));
+        }
+        json& operator[](unsigned int idx)
+        {
+            return static_cast<json&>(base::operator[](idx));
+        }
+        const json& operator[](unsigned int idx) const
+        {
+            return static_cast<const json&>(base::at(idx));
+        }
 
         using base::push_back;
         void push_back(const json& value)

src/db/sqler.cpp

@@ -52,6 +52,36 @@ bool checkAnyType(const std::any& value)
 		return false;
 	}
 }
+
+/// <summary>
+/// 入库前规范化 std::any：const char*/char* 立刻拷成 std::string，避免存指针到 exec 时悬空。
+/// </summary>
+static std::any normalize_sql_any(const std::any& value)
+{
+	if (!value.has_value()) {
+		return value;
+	}
+	if (value.type() == typeid(const char*)) {
+		const char* p = std::any_cast<const char*>(value);
+		return std::string(p != nullptr ? p : "");
+	}
+	if (value.type() == typeid(char*)) {
+		char* p = std::any_cast<char*>(value);
+		return std::string(p != nullptr ? p : "");
+	}
+	return value;
+}
+
+static std::vector<std::any> normalize_sql_any_list(const std::vector<std::any>& values)
+{
+	std::vector<std::any> out;
+	out.reserve(values.size());
+	for (size_t i = 0; i < values.size(); ++i) {
+		out.push_back(normalize_sql_any(values[i]));
+	}
+	return out;
+}
+
 /// <summary>
 /// 置入插入数据
 /// </summary>
@@ -60,6 +90,12 @@ bool checkAnyType(const std::any& value)
 /// <param name="value"></param>
 void setInsetValue(mysql::prepare_statement*ppst, uint32 index, const std::any& value)
 {
+	// 防御：若仍有指针（绕过 set/where 规范化），按字符串绑定
+	if (value.type() == typeid(const char*) || value.type() == typeid(char*)) {
+		std::any as_str = normalize_sql_any(value);
+		ppst->set_string(index, std::any_cast<std::string>(as_str));
+		return;
+	}
 	if (value.type() == typeid(int32)) {
 		ppst->set_int32(index,std::any_cast<int32>(value));
 	}
@@ -108,21 +144,24 @@ static void check_where_values(const std::vector<std::any>& values)
 
 static ylib::where make_where_in(const std::string& name, const std::vector<std::any>& values, bool not_in)
 {
-	check_where_values(values);
+	std::vector<std::any> normalized = normalize_sql_any_list(values);
+	check_where_values(normalized);
 	ylib::where w;
 	w.name = name;
-	w.values = values;
+	w.values = std::move(normalized);
 	w.type = not_in ? 7 : 6;
 	return w;
 }
 
 static ylib::where make_where_between(const std::string& name, const std::any& begin, const std::any& end, bool not_between)
 {
-	check_where_value(begin);
-	check_where_value(end);
+	std::any b = normalize_sql_any(begin);
+	std::any e = normalize_sql_any(end);
+	check_where_value(b);
+	check_where_value(e);
 	ylib::where w;
 	w.name = name;
-	w.values = { begin, end };
+	w.values = { b, e };
 	w.type = not_between ? 9 : 8;
 	return w;
 }
@@ -269,7 +308,7 @@ ylib::select& ylib::select::where(const std::string& name, const std::string& ex
 	ylib::where w;
 	w.name = name;
 	w.expression = expression;
-	w.value = value;
+	w.value = normalize_sql_any(value);
 	w.type = 0;
 	if (w.value.has_value() == false)
 	{
@@ -494,7 +533,7 @@ ylib::update& ylib::update::set(const std::string& name, const std::any& value)
 	struct update::set s;
 	s.type = 0;
 	s.name = name;
-	s.value = value;
+	s.value = normalize_sql_any(value);
 	m_sets.push_back(s);
 	return *this;
 }
@@ -513,7 +552,7 @@ ylib::update& ylib::update::where(const std::string& name, const std::string& ex
 	ylib::where w;
 	w.name = name;
 	w.expression = expression;
-	w.value = value;
+	w.value = normalize_sql_any(value);
 	w.type = 0;
 	if (w.value.has_value() == false)
 	{
@@ -705,7 +744,7 @@ ylib::insert& ylib::insert::table(const std::string& table_name)
 
 ylib::insert& ylib::insert::set(const std::string& name, const std::any& value)
 {
-	m_sets.push_back({name, value});
+	m_sets.push_back({name, normalize_sql_any(value)});
 	return *this;
 }
 
@@ -788,7 +827,7 @@ ylib::delete_& ylib::delete_::where(const std::string& name, const std::string&
 	ylib::where w;
 	w.name = name;
 	w.expression = expression;
-	w.value = value;
+	w.value = normalize_sql_any(value);
 	w.type = 0;
 	if (w.value.has_value() == false)
 	{

src/net/http_reqpack.cpp

@@ -33,6 +33,9 @@ ylib::network::http::reqpack::reqpack(const std::string& url, const std::string&
     ,m_msg_type(msg_type)
     ,m_ws_msg(ws_msg)
 {
+
+    m_create_time = time::now_msec();
+
     this->website(website);
     if(m_msg_type == network::http::HTTP_SERVER_MESSAGE_TYPE_WEBSOCKET){
         m_filepath = url;