code: public RecordWriter<K, V> getRecordWriter(FileSystem filesystem,
        JobConf job, String name, Progressable progress) throws IOException {
  
      DBConfiguration dbConf = new DBConfiguration(job);
      String tableName = dbConf.getOutputTableName();
      String[] fieldNames = dbConf.getOutputFieldNames();
      
      try {
        Connection connection = dbConf.getConnection();
        PreparedStatement statement = null;
    
        statement = connection.prepareStatement(constructQuery(tableName, fieldNames));
        return new DBRecordWriter(connection, statement);
      }
      catch (Exception ex) {
        throw new IOException(ex.getMessage());
      }
    }
docs: {@inheritDoc}