Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 771 - 780 of 1,127 for Upsert (0.2 seconds)

  1. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt

    import org.hamcrest.Matcher
    import org.hamcrest.MatcherAssert.assertThat
    import org.hamcrest.Matchers
    import org.intellij.lang.annotations.Language
    import org.junit.Assert.assertFalse
    import org.junit.Assert.assertTrue
    import org.junit.Rule
    import org.junit.rules.TemporaryFolder
    import java.io.File
    import java.nio.file.Files
    
    
    abstract class AbstractBinaryCompatibilityTest {
    
        @get:Rule
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Dec 30 10:14:25 GMT 2025
    - 18K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/core/collection/SLinkedListTest.java

    import static org.hamcrest.CoreMatchers.not;
    import static org.hamcrest.CoreMatchers.notNullValue;
    import static org.hamcrest.CoreMatchers.nullValue;
    import static org.junit.Assert.assertThat;
    import static org.junit.Assert.fail;
    
    import java.util.NoSuchElementException;
    
    import org.codelibs.core.exception.ClIndexOutOfBoundsException;
    import org.codelibs.core.io.SerializeUtil;
    import org.junit.Test;
    
    /**
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

            final OpenSearchUrlFilter esUrlFilter = new OpenSearchUrlFilter();
            esUrlFilter.setSessionId(sessionId);
            esUrlFilter.setFilterType(INCLUDE);
            esUrlFilter.setUrl(url);
            insert(esUrlFilter, OpType.INDEX);
            includeFilterCache.invalidate(sessionId);
        }
    
        /**
         * Adds multiple include URL filters for the specified session.
         *
         * @param sessionId The session ID.
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 9K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFileAuthenticationBhv.java

        //                                                                              ======
        public void insert(FileAuthentication entity) {
            doInsert(entity, null);
        }
    
        public void insert(FileAuthentication entity, RequestOptionCall<IndexRequestBuilder> opLambda) {
            entity.asDocMeta().indexOption(opLambda);
            doInsert(entity, null);
        }
    
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

     * limitations under the License.
     */
    
    package com.google.common.io;
    
    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Strings;
    import com.google.common.collect.ImmutableList;
    import java.io.EOFException;
    import java.io.FilterReader;
    import java.io.IOException;
    import java.io.Reader;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/io/CharStreamsTest.java

     * limitations under the License.
     */
    
    package com.google.common.io;
    
    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Strings;
    import com.google.common.collect.ImmutableList;
    import java.io.EOFException;
    import java.io.FilterReader;
    import java.io.IOException;
    import java.io.Reader;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/service/KuromojiService.java

         */
        public void store(final String dictId, final KuromojiItem kuromojiItem) {
            getKuromojiFile(dictId).ifPresent(file -> {
                if (kuromojiItem.getId() == 0) {
                    file.insert(kuromojiItem);
                } else {
                    file.update(kuromojiItem);
                }
            });
        }
    
        /**
         * Delete a Kuromoji item.
         *
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/suggest/normalizer/DefaultNormalizerTest.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.suggest.normalizer;
    
    import static org.codelibs.opensearch.runner.OpenSearchRunner.newConfigs;
    import static org.junit.Assert.assertEquals;
    
    import org.codelibs.fess.suggest.Suggester;
    import org.codelibs.fess.suggest.util.SuggestUtil;
    import org.codelibs.opensearch.runner.OpenSearchRunner;
    import org.junit.AfterClass;
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Sat Nov 01 13:29:47 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/app/service/RoleService.java

            return roleBhv.selectByPK(id);
        }
    
        /**
         * Stores a role.
         * @param role The role to store.
         */
        public void store(final Role role) {
            ComponentUtil.getLdapManager().insert(role);
    
            roleBhv.insertOrUpdate(role, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
    
        }
    
        /**
         * Deletes a role.
         * @param role The role to delete.
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/cache/AbstractLoadingCacheTest.java

     * limitations under the License.
     */
    
    package com.google.common.cache;
    
    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.ExecutionError;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import java.util.concurrent.ExecutionException;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 5K bytes
    - Click Count (0)
Back to Top