/**************************************************************************** ** ** https://www.qxorm.com/ ** Copyright (C) 2013 XDL Team (ic-east.com) ** ** This file is part of the QxOrm library ** ** This software is provided 'as-is', without any express or implied ** warranty. In no event will the authors be held liable for any ** damages arising from the use of this software ** ** Commercial Usage ** Licensees holding valid commercial QxOrm licenses may use this file in ** accordance with the commercial license agreement provided with the ** Software or, alternatively, in accordance with the terms contained in ** a written agreement between you and XDL Team ** ** GNU General Public License Usage ** Alternatively, this file may be used under the terms of the GNU ** General Public License version 3.0 as published by the Free Software ** Foundation and appearing in the file 'license.gpl3.txt' included in the ** packaging of this file. Please review the following information to ** ensure the GNU General Public License version 3.0 requirements will be ** met : http://www.gnu.org/copyleft/gpl.html ** ** If you are unsure which license is appropriate for your use, or ** if you have questions regarding the use of this file, please contact : ** ic-east.com ** ****************************************************************************/ namespace qx { namespace dao { namespace detail { template struct QxDao_Save_WithRelation_Generic { static QSqlError save(const QStringList &relation, T &t, QSqlDatabase *pDatabase) { qx::dao::detail::QxDao_Helper dao(t, pDatabase, "save with relation", new qx::QxSqlQueryBuilder_Update()); if (!dao.isValid()) { return dao.error(); } if (!dao.updateSqlRelationX(relation)) { return dao.errInvalidRelation(); } if (!pDatabase) { dao.transaction(); } dao.quiet(); qx_bool bExist = dao.isValidPrimaryKey(t); if (bExist) { bExist = qx::dao::exist(t, (&dao.database())); } if (bExist) { dao.updateError(qx::dao::update_with_relation(relation, t, (&dao.database()))); } else { dao.updateError(qx::dao::insert_with_relation(relation, t, (&dao.database()))); } return dao.error(); } }; template struct QxDao_Save_WithRelation_Container { static QSqlError save(const QStringList &relation, T &t, QSqlDatabase *pDatabase) { typedef typename qx::trait::generic_container::type_value_qx type_item; if (qx::trait::generic_container::size(t) <= 0) { return QSqlError(); } qx::dao::detail::QxDao_Helper_Container dao(t, pDatabase, "save with relation", new qx::QxSqlQueryBuilder_Update()); if (!dao.isValid()) { return dao.error(); } if (!dao.updateSqlRelationX(relation)) { return dao.errInvalidRelation(); } if (!pDatabase) { dao.transaction(); } dao.quiet(); for (typename T::iterator it = t.begin(); it != t.end(); ++it) { if (!saveItem(relation, (*it), dao)) { return dao.error(); } } return dao.error(); } private: template static inline bool saveItem(const QStringList &relation, U &item, qx::dao::detail::QxDao_Helper_Container &dao) { bool bSaveOk = saveItem_Helper < U, std::is_pointer::value || qx::trait::is_smart_ptr::value > ::save(relation, item, dao); if (bSaveOk) { qx::dao::detail::QxDao_Keep_Original::backup(item); } return bSaveOk; } template struct saveItem_Helper { static inline bool save(const QStringList &relation, U &item, qx::dao::detail::QxDao_Helper_Container &dao) { return (item ? qx::dao::detail::QxDao_Save_WithRelation_Container::saveItem(relation, (*item), dao) : false); } }; template struct saveItem_Helper, false> { static inline bool save(const QStringList &relation, std::pair &item, qx::dao::detail::QxDao_Helper_Container &dao) { return qx::dao::detail::QxDao_Save_WithRelation_Container::saveItem(relation, item.second, dao); } }; template struct saveItem_Helper, false> { static inline bool save(const QStringList &relation, const std::pair &item, qx::dao::detail::QxDao_Helper_Container &dao) { return qx::dao::detail::QxDao_Save_WithRelation_Container::saveItem(relation, item.second, dao); } }; #if (QT_VERSION < QT_VERSION_CHECK(6, 0, 0)) template struct saveItem_Helper, false> { static inline bool save(const QStringList &relation, QPair &item, qx::dao::detail::QxDao_Helper_Container &dao) { return qx::dao::detail::QxDao_Save_WithRelation_Container::saveItem(relation, item.second, dao); } }; template struct saveItem_Helper, false> { static inline bool save(const QStringList &relation, const QPair &item, qx::dao::detail::QxDao_Helper_Container &dao) { return qx::dao::detail::QxDao_Save_WithRelation_Container::saveItem(relation, item.second, dao); } }; #endif // (QT_VERSION < QT_VERSION_CHECK(6, 0, 0)) template struct saveItem_Helper { static bool save(const QStringList &relation, U &item, qx::dao::detail::QxDao_Helper_Container &dao) { qx_bool bExist = dao.isValidPrimaryKey(item); if (bExist) { bExist = qx::dao::exist(item, (&dao.database())); } if (bExist) { dao.updateError(qx::dao::update_with_relation(relation, item, (&dao.database()))); } else { dao.updateError(qx::dao::insert_with_relation(relation, item, (&dao.database()))); } return dao.isValid(); } }; }; template struct QxDao_Save_WithRelation_Ptr { static inline QSqlError save(const QStringList &relation, T &t, QSqlDatabase *pDatabase) { return (t ? qx::dao::save_with_relation(relation, (*t), pDatabase) : QSqlError()); } }; template struct QxDao_Save_WithRelation { static inline QSqlError save(const QString &relation, T &t, QSqlDatabase *pDatabase) { QStringList lst; if (!relation.isEmpty()) { lst = relation.split("|"); } return QxDao_Save_WithRelation::save(lst, t, pDatabase); } static inline QSqlError save(const QStringList &relation, T &t, QSqlDatabase *pDatabase) { typedef typename std::conditional::value, qx::dao::detail::QxDao_Save_WithRelation_Ptr, qx::dao::detail::QxDao_Save_WithRelation_Generic>::type type_dao_1; typedef typename std::conditional::value, qx::dao::detail::QxDao_Save_WithRelation_Ptr, type_dao_1>::type type_dao_2; typedef typename std::conditional::value, qx::dao::detail::QxDao_Save_WithRelation_Container, type_dao_2>::type type_dao_3; QSqlError error = type_dao_3::save(relation, t, pDatabase); if (!error.isValid()) { qx::dao::detail::QxDao_Keep_Original::backup(t); } return error; } }; } // namespace detail } // namespace dao } // namespace qx