Comment sélectionner les données d'une table et de l'insérer dans une autre table?

Je veux sélectionner des champs d'une table de cassandra et de les insérer dans une autre table. Je le fais dans sql server comme ceci:

INSERT INTO Users(name,family)
SELECT name,family FROM Users

Comment cette cassandra-cli ou cqlsh?

dans votre tableau est leur colonne avec l'UUID type de données?
Double Possible de cassandra copier des données d'un columnfamily à l'autre columnfamily

OriginalL'auteur ehsan shirzadi | 2014-01-26

  1. 24
    COPY keyspace.columnfamily1 (column1, column2,...) TO 'temp.csv';
COPY keyspace.columnfamily2 (column1, column2,...) FROM 'temp.csv';

    ici de donner à votre espace(schéma de nom) et au lieu de columnfamilyname1 utiliser la table à laquelle vous souhaitez copier et columnfamily2 donner le nom de la table dans laquelle vous souhaitez copier..

    Et oui c'est la solution pour CQL jamais essayé avec de la CLI..

    OriginalL'auteur Working Hard..

  2. 4

    Pour les tables qui ne sont pas très grandes, enregistrer vous-même le fichier et d'utiliser un canal anonyme:

    cqlsh -e "COPY keyspace.src_table (col1, col2, ...,ColN ) TO STDOUT WITH HEADER=false" | cqlsh -e "COPY keyspace.target_table (col1, col2, ...,ColN ) FROM STDIN"

    Pour de très grands ensembles de données, cela ne fonctionne pas. Une stratégie de par jeton de gamme devrait être exploré

    OriginalL'auteur Jose Martinez

  3. 2

    Pour les très grandes tables, CQLSH aurez un moment difficile de la manipulation de la COPIE. Voici comment faire pour balayer la table locale de jeton de plages et de copie souhaité les colonnes d'un tableau à l'autre. Parce qu'il utilise la copie locale, c'est d'être exécutée sur chaque nœud du Datacenter:

        #!/bin/bash
    #
    # Script to COPY from a SOURCE table's select columns over a TARGET table
    # Assumes the following:
    #
    # * The SOURCE table is very large - otherwise just try:
    #   cqlsh  -e "COPY keyspace.src_table (col1, col2, ...,ColN ) TO STDOUT WITH HEADER=false" \
    #   |cqlsh -e "COPY keyspace.tgt_table (col1, col2, ...,ColN ) FROM STDIN"
    # * SOURCE AND TARGET TABLES are in the SAME KEYSPACE
    # * TARGET columns are named the SAME as SOURCE
    #
    # The script sweeps thru the local tokens to copy only the local data over to the new table
    # Therefore, this script needs to run on every node on the datacenter
    #
    # Set these variables before executing
    #
    USR=cassandra
    PWD=password
    KSP=my_keyspace
    SRC=src_table
    COL="col1, col2, col3"
    PKY="col1"
    TGT=tgt_table

    CQLSH="cqlsh -u ${USR} -p ${PWD} -k ${KSP}"

    function getTokens(){
       for i in $($CQLSH -e "select tokens from system.local;" | awk -F, '/{/{print $0}' | tr -d '{' | tr -d '}' | tr -d ','); do
           echo ${i//\'/}
       done | sort -n
    }

    function getDataByTokenRange(){
       i=0
       tokens=($(getTokens))
       while [ ${i} -lt ${#tokens[@]} ]; do 
             [ ${i} -eq 0 ]         && echo "SELECT ${COL} FROM ${SRC} WHERE token(${PKY}) <= ${tokens[i]};" 
             [ "${tokens[i+1]}" ]   && echo "SELECT ${COL} FROM ${SRC} WHERE token(${PKY}) >  ${tokens[i]} AND token(${PKY}) <= ${tokens[i+1]};"
             [ ! "${tokens[i+1]}" ] && echo "SELECT ${COL} FROM ${SRC} WHERE token(${PKY}) >  ${tokens[i]};"
             ((i++))
       done
    } 

function cqlExec(){ 
  while IFS='' read -r cql || [[ -n "$line" ]]; do
    $CQLSH -e "CONSISTENCY LOCAL_ONE; $cql"                                                                \
    |awk -F\| '( !/LOCAL_ONE/&& !/'"${COL/, /|}"'/&& !/^\-+/&& !/^\([0-9]+ rows)/&& !/^$/){print $0}' \
    |sed -e 's/^[ ]*//g' -e 's/[ ]*|[ ]*/|/g'                                                              \
    |$CQLSH -e "COPY ${TGT} (${COL}) FROM STDIN WITH DELIMITER = '|' and HEADER=false;"
    [ "$?" -gt 0 ] && echo "ERROR: Failed to import data from command: ${command}"
  done < "$1"
}

    main(){
       echo "Begin processing ..."
       getDataByTokenRange > getDataByTokenRange.ddl
       cqlExec getDataByTokenRange.ddl
       echo "End procesing"
    }

    main

    OriginalL'auteur Jose Martinez