if (StringUtil.isBlank(fessConfig.getSchedulerTargetName())) {
                cb.query().setTarget_Equal(Constants.DEFAULT_JOB_TARGET);
            } else {
                cb.query().setTarget_InScope(Lists.newArrayList(Constants.DEFAULT_JOB_TARGET, fessConfig.getSchedulerTargetName()));
            }
            cb.query().addOrderBy_CreatedTime_Asc();

        // Verify file information class
        assertEquals(Smb2QueryDirectoryRequest.FILE_ID_FULL_DIRECTORY_INFO, buffer[Smb2Constants.SMB2_HEADER_LENGTH + 2]);

        // Verify query flags
        assertEquals(Smb2QueryDirectoryRequest.SMB2_INDEX_SPECIFIED, buffer[Smb2Constants.SMB2_HEADER_LENGTH + 3]);

        // Verify file index
        int readFileIndex =

     */
    protected OptionalEntity<FessUser> doFindLoginUser(final String username, final String cipheredPassword) {
        return userBhv.selectEntity(cb -> {
            cb.query().setName_Equal(username);
            cb.query().setPassword_Equal(cipheredPassword);
        }).map(user -> (FessUser) user);
    }

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

import org.apache.lucene.queryparser.classic.ParseException;

/**
 * Exception thrown when a query parsing error occurs.
 * This exception wraps Lucene's ParseException to provide consistent error handling
 * within the Fess search framework.
 *
 */
public class QueryParseException extends FessSystemException {

     */
    @ValidateTypeFailure
    public Integer crudMode;

    /**
     * The document data for search list operations.
     */
    public Map<String, Object> doc;

    /**
     * The search query string.
     */
    public String q;

    /**
     * Initializes the form with default values for search list operations.
     */
    public void initialize() {
        crudMode = CrudMode.CREATE;
    }

from pydantic.fields import FieldInfo
from typing_extensions import Literal, deprecated

from ._compat import (
    Undefined,
)

_Unset: Any = Undefined


class ParamTypes(Enum):
    query = "query"
    header = "header"
    path = "path"
    cookie = "cookie"


class Param(FieldInfo):  # type: ignore[misc]
    in_: ParamTypes

    def __init__(
        self,
        default: Any = Undefined,

		var first, last User
		if err := DB.Where("id = ?", users[0].ID).First(&first).Error; err != nil {
			t.Errorf("errors happened when query before user: %v", err)
		}
		CheckUser(t, first, *users[0])

		if err := DB.Where("id = ?", users[2].ID).First(&last).Error; err != nil {
			t.Errorf("errors happened when query after user: %v", err)
		}
		CheckUser(t, last, *users[2])
	}

	if err := DB.Create(&users).Error; err != nil {

def write_log(message: str):
    with open("log.txt", mode="a") as log:
        log.write(message)


def get_query(background_tasks: BackgroundTasks, q: str | None = None):
    if q:
        message = f"found query: {q}\n"
        background_tasks.add_task(write_log, message)
    return q


@app.post("/send-notification/{email}")
async def send_notification(

errors.failed_to_delete_doc_in_admin = Failed to delete a document.
errors.failed_to_send_testmail=Failed to send a test mail.
errors.invalid_query_unknown = The specified query has an unknown condition.
errors.invalid_query_parse_error = The given query is invalid.
errors.invalid_query_sort_value = The specified sort {0} is invalid.
errors.invalid_query_unsupported_sort_field = The specified sort {0} is unsupported.

errors.failed_to_delete_doc_in_admin = Failed to delete a document.
errors.failed_to_send_testmail=Failed to send a test mail.
errors.invalid_query_unknown = The specified query has an unknown condition.
errors.invalid_query_parse_error = The given query is invalid.
errors.invalid_query_sort_value = The specified sort {0} is invalid.
errors.invalid_query_unsupported_sort_field = The specified sort {0} is unsupported.