async getByQuery(query = {}) {
    const connection = await pool.getConnection();
    try {
      let dbQuery = "SELECT * FROM srv_lead_with_broker_name_transferred";
      let params = [];
      if (Object.keys(query).length > 0) {
        dbQuery += " WHERE ";
        for (const prop in query) {
          if (query[prop] !== "") {
            if (prop === "utm_campaign") {
              dbQuery += `${prop} = ? AND `;
              params.push(query[prop]);
            } else {
              // Kullanıcının değeri joker karakterleriyle birleştir
              let value = `%${query[prop]}%`;
              dbQuery += `${prop} LIKE ? AND `;
              params.push(value);
            }
          }
        }
        dbQuery = dbQuery.substring(0, dbQuery.length - 5); // Remove the last 'AND' from the query
      }
      dbQuery += " ORDER BY COALESCE(updated_at, created_at) DESC"; 
      const [rows, fields] = await connection.query(dbQuery, params);
      return rows;
    } finally {
      connection.release();
    }
  }