code: public static void createSchema(DataSource dataSource, String name) {
          try (Connection connection = dataSource.getConnection();
               Statement statement = connection.createStatement()) {
              statement.executeUpdate(String.format(Constants.DDL_CREATE_SCHEMA, name));
          } catch (SQLException e) {
              throw new RuntimeException("Can not connect to database", e);
          }
      }
docs: Creates new database scheme.
  
  @param dataSource the datasource
  @param name       schema name