Java 类org.springframework.jdbc.core.simple.SimpleJdbcInsert 实例源码

项目：petclinic 文件：JdbcOwnerDAO.java

@Autowired
public JdbcOwnerDAO(DataSource dataSource) {
  setDataSource(dataSource);
  insertActor = new SimpleJdbcInsert(dataSource).withTableName("owners").usingGeneratedKeyColumns("id");

  ownerRowMapper = (rs, rowNum) -> {
    Owner owner = new Owner();
    owner.setId(rs.getInt("id"));
    owner.setFirstName(rs.getString("first_name"));
    owner.setLastName(rs.getString("last_name"));
    owner.setAddress(rs.getString("address"));
    owner.setCity(rs.getString("city"));
    owner.setTelephone(rs.getString("telephone"));
    return owner;
  };
}

项目：springmvc-architecture-gradle 文件：BookDaoImpl.java

/**
 * Insert a new Book into the database.
 * 
 * @throws RuntimeException
 *             if id is not null
 */
@Override
public Book save(Book book) {
    if (book.getId() == null) {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("title", book.getTitle());
        map.put("author", book.getAuthor());
        SimpleJdbcInsert sji = new SimpleJdbcInsert(getJdbcTemplate());
        sji.setTableName("book");
        sji.setGeneratedKeyName("id");
        Long id = (Long) sji.executeAndReturnKey(map);
        book.setId(id);
        return book;
    } else {
        throw new RuntimeException("Book exist");
    }
}

项目：summerb 文件：UserDaoImpl.java

@Override
public void afterPropertiesSet() throws Exception {
    rowMapper = new BeanPropertyRowMapper<User>(User.class);
    jdbcInsert = new SimpleJdbcInsert(getDataSource()).withTableName(tableName);

    sqlSelectUserByUuid = String.format("SELECT * FROM %s u WHERE u.uuid = :userUuid", tableName);
    sqlSelectUserByEmail = String.format("SELECT * FROM %s u WHERE u.email = :userEmail", tableName);
    sqlDeleteUserByUuid = String.format("DELETE FROM %s WHERE uuid = :userUuid", tableName);
    sqlUpdateUser = String.format(
            "UPDATE %s SET display_name = :displayName, email = :email, time_zone = :timeZone, locale = :locale, is_blocked = :isBlocked, integration_data = :integrationData WHERE uuid = :uuid",
            tableName);

    sqlSearchUsersByDisplayName = String.format(
            "SELECT SQL_CALC_FOUND_ROWS u.*, INSTR(u.display_name, :displayNameAsIs) as ddd FROM %s u WHERE u.display_name LIKE :displayName ORDER BY ddd ASC, u.display_name LIMIT :offset,:max",
            tableName);
    sqlSearchUsersByDisplayNameGetCount = "SELECT FOUND_ROWS()";
}

项目：sakuli 文件：DaoTestSuiteImpl.java

/**
 * {@inheritDoc}
 */
@Override
public int insertInitialTestSuiteData() {
    LOGGER.debug("Build SQL query for new primary key in table 'sakuli_suites'");

    testSuite.refreshState();
    MapSqlParameterSource tcParameters = getInitialDataParameters();
    LOGGER.debug("write the following values to 'sakuli_suites': "
            + tcParameters.getValues()
            + " ==>  now execute ....");
    SimpleJdbcInsert insertInitialSuiteData = new SimpleJdbcInsert(getDataSource())
            .withTableName("sakuli_suites")
            .usingGeneratedKeyColumns("id");

    int dbPrimaryKey = insertInitialSuiteData.executeAndReturnKey(tcParameters).intValue();

    LOGGER.info("test suite \"" + testSuite.getId()
            + "\" has been written to 'sakuli_suites' with  primaryKey=" + dbPrimaryKey);
    return dbPrimaryKey;
}

项目：sakuli 文件：DaoTestSuiteImpl.java

@Override
public int saveTestSuiteToSahiJobs() {
    LOGGER.debug("save the guid to the table 'sakuli_jobs'");
    //build up the statement
    MapSqlParameterSource tcParameters = getGuidParameter();
    LOGGER.debug("write the following values to 'sakuli_jobs': "
            + tcParameters.getValues()
            + " ==>  now execute ....");
    SimpleJdbcInsert insertTS = new SimpleJdbcInsert(getDataSource())
            .withTableName("sakuli_jobs")
            .usingGeneratedKeyColumns("id");
    testSuite.setDbJobPrimaryKey(insertTS.executeAndReturnKey(tcParameters).intValue());
    LOGGER.info("the test suite \"" + testSuite.getId() + "\""
            + "with the guid \"" + testSuite.getGuid()
            + "\" has been written to 'sakuli_jobs' with  primaryKey=" + testSuite.getDbJobPrimaryKey());
    return testSuite.getDbJobPrimaryKey();
}

项目：cluster-repo 文件：ClusterWriter.java

@Override
public void saveSpectrum(final SpectrumDetail spectrum) {
    logger.debug("Insert a spectrum into database: {}", spectrum.getReferenceId());

    SimpleJdbcInsert simpleJdbcInsert = new SimpleJdbcInsert(template);

    simpleJdbcInsert.withTableName("spectrum").usingGeneratedKeyColumns("spectrum_pk");

    HashMap<String, Object> parameters = new HashMap<String, Object>();
    parameters.put("assay_fk", spectrum.getAssayId());
    parameters.put("spectrum_ref", spectrum.getReferenceId());
    parameters.put("precursor_mz", spectrum.getPrecursorMz());
    parameters.put("precursor_charge", spectrum.getPrecursorCharge());
    parameters.put("is_identified", spectrum.isIdentified());

    Number key = simpleJdbcInsert.executeAndReturnKey(new MapSqlParameterSource(parameters));
    spectrum.setId(key.longValue());
}

项目：cluster-repo 文件：SpectrumLibraryWriter.java

@Override
public void saveSpectrumLibrary(SpectrumLibraryDetail spectrumLibraryDetail) {
    logger.debug("Inserting a spectral library detail record");

    SimpleJdbcInsert simpleJdbcInsert = new SimpleJdbcInsert(template);

    simpleJdbcInsert.withTableName("spectral_library");

    Map<String, Object> parameters = new HashMap<String, Object>();
    parameters.put("release_version", spectrumLibraryDetail.getVersion());
    parameters.put("release_date", spectrumLibraryDetail.getReleaseDate());
    parameters.put("taxonomy_id", spectrumLibraryDetail.getTaxonomyId());
    parameters.put("species_scientific_name", spectrumLibraryDetail.getSpeciesScientificName());
    parameters.put("species_name", spectrumLibraryDetail.getSpeciesName());
    parameters.put("number_of_spectra", spectrumLibraryDetail.getNumberOfSpectra());
    parameters.put("number_of_peptides", spectrumLibraryDetail.getNumberOfPeptides());
    parameters.put("file_size", spectrumLibraryDetail.getFileSize());
    parameters.put("file_name", spectrumLibraryDetail.getFileName());

    MapSqlParameterSource parameterSource = new MapSqlParameterSource(parameters);
    parameterSource.registerSqlType("release_date", Types.DATE);

    simpleJdbcInsert.execute(parameterSource);
}

项目：mycollab 文件：V20150401_2__Insert_Default_Values.java

public void migrate(JdbcTemplate jdbcTemplate) throws Exception {
    LOG.info("Set up initial values");

    LOG.debug("Insert default billing plan");
    SimpleJdbcInsert billingJdbcInsert = new SimpleJdbcInsert(jdbcTemplate).withTableName("s_billing_plan")
            .usingColumns("billingType", "numUsers", "volume", "numProjects", "pricing").usingGeneratedKeyColumns("id");

    Map<String, Object> billingParameters = new HashMap<>();
    billingParameters.put("billingType", "Community");
    billingParameters.put("numUsers", 99999999);
    billingParameters.put("volume", 999999999999L);
    billingParameters.put("numProjects", 999999);
    billingParameters.put("pricing", 0);

    Number billingPlanId = billingJdbcInsert.executeAndReturnKey(billingParameters);

    LOG.debug("Insert default account");
    SimpleJdbcInsert accountJdbcInsert = new SimpleJdbcInsert(jdbcTemplate).withTableName("s_account")
            .usingColumns("status", "billingPlanId", "paymentMethod", "subdomain").usingGeneratedKeyColumns("id");
    Map<String, Object> accountParameters = new HashMap<>();
    accountParameters.put("status", "Active");
    accountParameters.put("billingPlanId", billingPlanId);
    accountParameters.put("paymentMethod", "None");
    accountParameters.put("subdomain", "");
    accountJdbcInsert.executeAndReturnKey(accountParameters);
}

项目：pluggable 文件：SecurityUtilities.java

public static final void grantJdbcAccess(JdbcTemplate jdbcTemplate,
        Group group, Role role) {
    long count = jdbcTemplate.queryForObject(
            "select count(*) from "
                    + TableUtilities.getTableName(RoleGroup.class)
                    + " where " + RoleGroup.ROLE_ID + " = ? and "
                    + RoleGroup.GROUP_ID + " = ?", Long.class,
            role.getId(), group.getId());
    if (count <= 0) {
        SimpleJdbcInsert insert = new SimpleJdbcInsert(jdbcTemplate);
        insert.withTableName(TableUtilities.getTableName(RoleGroup.class));
        Map<String, Object> fields = new HashMap<String, Object>();
        fields.put(RoleGroup.ROLE_ID, role.getId());
        fields.put(RoleGroup.GROUP_ID, group.getId());
        insert.execute(fields);
    }
}

项目：pluggable 文件：SecurityUtilities.java

public static final void grantAccess(JdbcTemplate jdbcTemplate,
        Long userId, Group group) {
    long count = jdbcTemplate.queryForObject(
            "select count(*) from "
                    + TableUtilities.getTableName(UserGroup.class)
                    + " where " + UserGroup.USER_ID + " = ? and "
                    + UserGroup.GROUP_ID + " = ?", Long.class, userId,
            group.getId());
    if (count <= 0) {
        SimpleJdbcInsert insert = new SimpleJdbcInsert(jdbcTemplate);
        insert.withTableName(TableUtilities.getTableName(UserGroup.class));
        Map<String, Object> fields = new HashMap<String, Object>();
        fields.put(UserGroup.GROUP_ID, group.getId());
        fields.put(UserGroup.USER_ID, userId);
        insert.execute(fields);
    }
}

项目：pluggable 文件：RegistryUtilities.java

public static final void update(Gson gson, JdbcTemplate jdbcTemplate, String identity, String name, Object value) {
    PluginSetting pluginSetting = null;
    try {
        pluginSetting = jdbcTemplate.queryForObject("select * from " + TableUtilities.getTableName(PluginSetting.class) + " where " + PluginSetting.IDENTITY + " = ? and " + PluginSetting.NAME + " = ?", new PluginSettingMapper(), identity, name);
    } catch (EmptyResultDataAccessException e) {
    }
    if (pluginSetting != null) {
        jdbcTemplate.update("update " + TableUtilities.getTableName(PluginSetting.class) + " set value = ? where " + PluginSetting.IDENTITY + " = ? and " + PluginSetting.NAME + " = ?", gson.toJson(value), identity, name);
    } else {
        SimpleJdbcInsert insert = new SimpleJdbcInsert(jdbcTemplate);
        insert.withTableName(TableUtilities.getTableName(PluginSetting.class));
        Map<String, Object> fields = new HashMap<String, Object>();
        fields.put(PluginSetting.IDENTITY, identity);
        fields.put(PluginSetting.NAME, name);
        fields.put(PluginSetting.VALUE, gson.toJson(value));
        insert.execute(fields);
    }
}

项目：pluggable 文件：RegistryUtilities.java

public static final void update(Gson gson, JdbcTemplate jdbcTemplate, String name, Object value) {
    ApplicationSetting applicationSetting = null;
    try {
        applicationSetting = jdbcTemplate.queryForObject("select * from " + TableUtilities.getTableName(ApplicationSetting.class) + " where " + ApplicationSetting.NAME + " = ?", new ApplicationSettingMapper(), name);
    } catch (EmptyResultDataAccessException e) {
    }
    if (applicationSetting != null) {
        jdbcTemplate.update("update " + TableUtilities.getTableName(ApplicationSetting.class) + " set value = ? where " + ApplicationSetting.NAME + " = ?", gson.toJson(value), name);
    } else {
        SimpleJdbcInsert insert = new SimpleJdbcInsert(jdbcTemplate);
        insert.withTableName(TableUtilities.getTableName(ApplicationSetting.class));
        Map<String, Object> fields = new HashMap<String, Object>();
        fields.put(ApplicationSetting.NAME, name);
        fields.put(ApplicationSetting.VALUE, gson.toJson(value));
        insert.execute(fields);
    }
}

项目：spring-data-jdbc-template 文件：JdbcTemplateRepositoryInternal.java

private SimpleJdbcInsert createJdbcInsert() {
    JdbcTemplate jdbcTemplate = (JdbcTemplate) operations().getJdbcOperations();
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(jdbcTemplate);

    jdbcInsert.withTableName(EntityUtils.tableName(domainClass));
    Set<String> usingColumns = EntityUtils.columnNamesExceptGeneratedValues(domainClass);
    jdbcInsert.usingColumns(usingColumns.toArray(new String[usingColumns.size()]));

    return jdbcInsert;
}

项目：spring-data-jdbc-template 文件：JdbcTemplateRepositoryInternal.java

@Override
public void insert(T entity) {
    callBeforeInsert(entity);

    SimpleJdbcInsert jdbcInsert = createJdbcInsert();
    Map<String, Object> values = EntityUtils.values(entity, domainClass, false);

    jdbcInsert.execute(values);
    callAfterInsert(entity);
}

项目：travelimg 文件：JDBCPhotographerDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertPhotographer = new SimpleJdbcInsert(dataSource)
            .withTableName("Photographer")
            .usingGeneratedKeyColumns("id");
}

项目：travelimg 文件：JDBCPhotoDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertPhoto = new SimpleJdbcInsert(dataSource)
            .withTableName("Photo")
            .usingGeneratedKeyColumns("id");
}

项目：travelimg 文件：JDBCJourneyDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertJourney = new SimpleJdbcInsert(dataSource).withTableName("Journey")
            .usingGeneratedKeyColumns("id");
}

项目：travelimg 文件：JDBCTagDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertTag = new SimpleJdbcInsert(dataSource).withTableName("Tag")
            .usingGeneratedKeyColumns("id");
}

项目：travelimg 文件：JDBCDirectoryPathDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertDirectory = new SimpleJdbcInsert(dataSource)
            .withTableName("WorkspaceDirectory");
}

项目：travelimg 文件：JDBCSlideshowDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertSlideshow = new SimpleJdbcInsert(dataSource)
            .withTableName("Slideshow")
            .usingGeneratedKeyColumns("id");
}

项目：travelimg 文件：JDBCPlaceDAO.java

@Override
@Autowired
public void setDataSource(DataSource dataSource) {
    super.setDataSource(dataSource);
    this.insertPlace = new SimpleJdbcInsert(dataSource).withTableName("Place")
            .usingGeneratedKeyColumns("id");
}

项目：DevOps-for-Web-Development 文件：JdbcVisitRepositoryImpl.java

@Autowired
public JdbcVisitRepositoryImpl(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);

    this.insertVisit = new SimpleJdbcInsert(dataSource)
        .withTableName("visits")
        .usingGeneratedKeyColumns("id");
}

项目：DevOps-for-Web-Development 文件：JdbcPetRepositoryImpl.java

@Autowired
public JdbcPetRepositoryImpl(DataSource dataSource, OwnerRepository ownerRepository, VisitRepository visitRepository) {
    this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);

    this.insertPet = new SimpleJdbcInsert(dataSource)
        .withTableName("pets")
        .usingGeneratedKeyColumns("id");

    this.ownerRepository = ownerRepository;
    this.visitRepository = visitRepository;
}

项目：DevOps-for-Web-Development 文件：JdbcVisitRepositoryImpl.java

@Autowired
public JdbcVisitRepositoryImpl(DataSource dataSource) {
    this.jdbcTemplate = new NamedParameterJdbcTemplate(dataSource);

    this.insertVisit = new SimpleJdbcInsert(dataSource)
        .withTableName("visits")
        .usingGeneratedKeyColumns("id");
}

项目：DevOps-for-Web-Development 文件：JdbcPetRepositoryImpl.java

@Autowired
public JdbcPetRepositoryImpl(DataSource dataSource, OwnerRepository ownerRepository, VisitRepository visitRepository) {
    this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);

    this.insertPet = new SimpleJdbcInsert(dataSource)
        .withTableName("pets")
        .usingGeneratedKeyColumns("id");

    this.ownerRepository = ownerRepository;
    this.visitRepository = visitRepository;
}

项目：MBaaS 文件：Serializable.java

public static void insert(DataSource dataSource, String tableName, List<String> usingColumns, List<Map<String, Object>> fields) {
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(dataSource);
    jdbcInsert.withTableName(tableName);
    List<String> pp = new ArrayList<>();
    pp.addAll(usingColumns);
    pp.add(tableName + "_id");
    jdbcInsert.usingColumns(pp.toArray(new String[usingColumns.size()]));
    for (Map<String, Object> field : fields) {
        field.put(tableName + "_id", UUID.randomUUID().toString());
    }
    Map<String, Object>[] batch = fields.toArray(new Map[fields.size()]);
    jdbcInsert.executeBatch(batch);
}

项目：MBaaS 文件：ReadUnCommitted.java

public static void insert(DataSource dataSource, String tableName, List<String> usingColumns, List<Map<String, Object>> fields) {
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(dataSource);
    jdbcInsert.withTableName(tableName);
    List<String> pp = new ArrayList<>();
    pp.addAll(usingColumns);
    pp.add(tableName + "_id");
    jdbcInsert.usingColumns(pp.toArray(new String[usingColumns.size()]));
    for (Map<String, Object> field : fields) {
        field.put(tableName + "_id", UUID.randomUUID().toString());
    }
    Map<String, Object>[] batch = fields.toArray(new Map[fields.size()]);
    jdbcInsert.executeBatch(batch);
}

项目：MBaaS 文件：Source.java

@SuppressWarnings("unchecked")
public static void insert(DataSource dataSource, String tableName, List<String> usingColumns, List<Map<String, Object>> fields) {
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(dataSource);
    jdbcInsert.withTableName(tableName);
    List<String> pp = new ArrayList<>();
    pp.addAll(usingColumns);
    pp.add(tableName + "_id");
    jdbcInsert.usingColumns(pp.toArray(new String[usingColumns.size()]));
    for (Map<String, Object> field : fields) {
        field.put(tableName + "_id", UUID.randomUUID().toString());
    }
    Map<String, Object>[] batchs = fields.toArray(new Map[fields.size()]);
    jdbcInsert.executeBatch(batchs);
}

项目：MBaaS 文件：ReadCommitted.java

public static void insert(DataSource dataSource, String tableName, List<String> usingColumns, List<Map<String, Object>> fields) {
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(dataSource);
    jdbcInsert.withTableName(tableName);
    List<String> pp = new ArrayList<>();
    pp.addAll(usingColumns);
    pp.add(tableName + "_id");
    jdbcInsert.usingColumns(pp.toArray(new String[usingColumns.size()]));
    for (Map<String, Object> field : fields) {
        field.put(tableName + "_id", UUID.randomUUID().toString());
    }
    Map<String, Object>[] batch = fields.toArray(new Map[fields.size()]);
    jdbcInsert.executeBatch(batch);
}

项目：MBaaS 文件：RepeatableRead.java

public static void insert(DataSource dataSource, String tableName, List<String> usingColumns, List<Map<String, Object>> fields) {
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(dataSource);
    jdbcInsert.withTableName(tableName);
    List<String> pp = new ArrayList<>();
    pp.addAll(usingColumns);
    pp.add(tableName + "_id");
    jdbcInsert.usingColumns(pp.toArray(new String[usingColumns.size()]));
    for (Map<String, Object> field : fields) {
        field.put(tableName + "_id", UUID.randomUUID().toString());
    }
    Map<String, Object>[] batch = fields.toArray(new Map[fields.size()]);
    jdbcInsert.executeBatch(batch);
}

项目：java-persistence-frameworks-comparison 文件：JDBCDataRepositoryImpl.java

@SuppressWarnings("SpringJavaAutowiringInspection")
@Autowired
public JDBCDataRepositoryImpl(NamedParameterJdbcTemplate jdbcTemplate) {
    this.jdbcTemplate = jdbcTemplate;
    this.insertIntoProject = new SimpleJdbcInsert((JdbcTemplate) jdbcTemplate.getJdbcOperations())
            .withTableName("project")
            .usingGeneratedKeyColumns("pid");
}

项目：petclinic 文件：JdbcPetDAO.java

@Autowired
public JdbcPetDAO(DataSource dataSource) {
  this.setDataSource(dataSource);
  simpleJdbcInsert = new SimpleJdbcInsert(dataSource).withTableName("pets").usingGeneratedKeyColumns("id");
  this.rowMapper = (rs, rowNum) -> {
    JdbcPet pet = new JdbcPet();
    pet.setId(rs.getInt("id"));
    pet.setName(rs.getString("name"));
    pet.setBirthDate(rs.getDate("birth_date"));
    pet.setOwnerId(rs.getInt("owner_id"));
    pet.setTypeId(rs.getInt("type_id"));
    return pet;
  };
}

项目：cacheonix-core 文件：SimpleJdbcClinic.java

@Autowired
public void init(DataSource dataSource) {
    this.simpleJdbcTemplate = new SimpleJdbcTemplate(dataSource);

    this.insertOwner = new SimpleJdbcInsert(dataSource)
        .withTableName("owners")
        .usingGeneratedKeyColumns("id");
    this.insertPet = new SimpleJdbcInsert(dataSource)
        .withTableName("pets")
        .usingGeneratedKeyColumns("id");
    this.insertVisit = new SimpleJdbcInsert(dataSource)
        .withTableName("visits")
        .usingGeneratedKeyColumns("id");
}

项目：trenurbanoapp 文件：StatsLogDaoJdbc.java

@Inject
public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
    this.tripLogInsert = new SimpleJdbcInsert(dataSource)
            .withSchemaName("logs")
            .withTableName("trip_log");
}

项目：trenurbanoapp 文件：VehicleStateDaoJdbc.java

@Inject
public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
    namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate);
    this.vehicleStateInsert = new SimpleJdbcInsert(dataSource)
            .withSchemaName("ref")
            .withTableName("vehicle_state");
    this.possibleSubroutesInsert = new SimpleJdbcInsert(dataSource)
            .withSchemaName("ref")
            .withTableName("vehicle_state_possible_subroutes");
    this.possibleGeofenceRoutesInsert = new SimpleJdbcInsert(dataSource)
            .withSchemaName("ref")
            .withTableName("vehicle_state_possible_routes");
}

项目：docker-workflow-plugin 文件：JdbcVisitRepositoryImpl.java

@Autowired
public JdbcVisitRepositoryImpl(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);

    this.insertVisit = new SimpleJdbcInsert(dataSource)
            .withTableName("visits")
            .usingGeneratedKeyColumns("id");
}

项目：docker-workflow-plugin 文件：JdbcOwnerRepositoryImpl.java

@Autowired
public JdbcOwnerRepositoryImpl(DataSource dataSource, NamedParameterJdbcTemplate namedParameterJdbcTemplate,
                               VisitRepository visitRepository) {

    this.insertOwner = new SimpleJdbcInsert(dataSource)
            .withTableName("owners")
            .usingGeneratedKeyColumns("id");

    this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);

    this.visitRepository = visitRepository;
}

项目：docker-workflow-plugin 文件：JdbcPetRepositoryImpl.java

@Autowired
public JdbcPetRepositoryImpl(DataSource dataSource, OwnerRepository ownerRepository, VisitRepository visitRepository) {
    this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);

    this.insertPet = new SimpleJdbcInsert(dataSource)
            .withTableName("pets")
            .usingGeneratedKeyColumns("id");

    this.ownerRepository = ownerRepository;
    this.visitRepository = visitRepository;
}

项目：summerb 文件：AuthTokenDaoImpl.java

@Override
public void afterPropertiesSet() throws Exception {
    rowMapper = new BeanPropertyRowMapper<AuthToken>(AuthToken.class);
    jdbcInsert = new SimpleJdbcInsert(getDataSource()).withTableName(tableName);

    sqlSelectTokenByUuid = String.format("SELECT * FROM %s u WHERE u.uuid = :authTokenUuid", tableName);
    sqlUpdateToken = String.format(
            "UPDATE %s SET last_verified_at = :lastVerifiedAt, token_value = :tokenValue WHERE uuid = :authTokenUuid AND last_verified_at < :lastVerifiedAt",
            tableName);
    sqlDeleteTokenByUuid = String.format("DELETE FROM %s WHERE uuid = :authTokenUuid", tableName);

    sqlSearchUserTokens = String.format("SELECT u.* FROM %s u WHERE u.user_uuid = :userUuid", tableName);
}

项目：summerb 文件：StringIdAliasDaoImpl.java

@Override
public void afterPropertiesSet() throws Exception {
    Assert.hasText(tableName, "Table name must be provided");
    jdbcInsert = new SimpleJdbcInsert(getDataSource()).withTableName(getTableName()).usingGeneratedKeyColumns("id");

    sqlFindAliasByName = String.format("SELECT alias FROM %s WHERE alias_name = :alias_name", tableName);
    sqlFindNameByAlias = String.format("SELECT alias_name FROM %s WHERE alias = :alias", tableName);

    sqlFindAllAliases = String.format(
            "SELECT SQL_CALC_FOUND_ROWS alias_name, alias FROM %s ORDER BY alias ASC LIMIT :offset,:max",
            tableName);
    sqlLastStatementCount = "SELECT FOUND_ROWS()";
}