bcp_setbulkmode
bcp_setbulkmode vous permet de spécifier le format de colonne dans une opération de copie en bloc, en définissant tous les attributs de colonne dans un appel de fonction unique.
Syntaxe
RETCODE bcp_setbulkmode (
HDBC hdbc,
INT property,
void * pField,
INT cbField,
void * pRow,
INT cbRow
);
Arguments
hdbc
Descripteur de connexion ODBC compatible avec la copie en bloc.property
Constante de type BYTE. Consultez le tableau dans la section Notes pour obtenir une liste des constantes.pField
Pointeur vers la valeur de marque de fin de champ.cbField
Longueur (en octets) de la valeur de marque de fin de champ.pRow
Pointeur vers la valeur de marque de fin de ligne.cbRow
Longueur, en octets, de la valeur de marque de fin de ligne.
Valeurs retournées
SUCCEED ou FAIL
Notes
bcp_setbulkmode peut être utilisé pour copier en bloc une requête ou une table. Lorsque bcp_setbulkmode est utilisé pour copier en bloc une instruction de requête, il doit être appelé avant d'appeler bcp_control avec BCP_HINT.
bcp_setbulkmode est une alternative à bcp_setcolfmt et bcp_columns, qui vous permettent uniquement de spécifier le format d'une colonne par appel de fonction.
Le tableau suivant répertorie les constantes du paramètre property.
Propriété |
Description |
|---|---|
BCP_OUT_CHARACTER_MODE |
Spécifie le mode de sortie de caractères. Correspond à l'option –c dans BCP.EXE, et à bcp_setcolfmt avec la propriété BCP_FMT_TYPE définie sur SQLCHARACTER. |
BCP_OUT_WIDE_CHARACTER_MODE |
Spécifie le mode de sortie Unicode. Correspond à l'option –w dans BCP.EXE, et à bcp_setcolfmt avec la propriété BCP_FMT_TYPE définie sur SQLNCHAR. |
BCP_OUT_NATIVE_TEXT_MODE |
Spécifie des types natifs pour les types de non-caractères et Unicode pour les types de caractères. Correspond à l'option –N dans BCP.EXE et bcp_setcolfmt avec la propriété BCP_FMT_TYPE définie sur SQLNCHAR si le type de colonne est une chaîne (valeur par défaut s'il ne s'agit pas d'une chaîne). |
BCP_OUT_NATIVE_MODE |
Spécifie les types de base de données natifs. Correspond à l'option –n dans BCP.EXE et bcp_setcolfmt avec la propriété BCP_FMT_TYPE définie sur la valeur par défaut. |
Vous ne devez pas utiliser bcp_setbulkmode avec une séquence d'appels de fonction qui inclut bcp_setcolfmt, bcp_control et bcp_readfmt. Par exemple, vous ne devez pas appeler bcp_control(BCPTEXTFILE) et bcp_setbulkmode.
Vous pouvez appeler bcp_control et bcp_setbulkmode pour les options bcp_control qui ne sont pas en conflit avec bcp_setbulkmode. Vous pouvez, par exemple, appeler bcp_control(BCPFIRST) et bcp_setbulkmode.
Si vous essayez d'appeler bcp_setbulkmode avec une séquence d'appels de fonction qui inclut bcp_setcolfmt, bcp_control et bcp_readfmt, l'un des appels de fonction se soldera par un échec d'erreur de séquence. Si vous choisissez de corriger l'échec, appelez bcp_init pour réinitialiser tous les paramètres et recommencer.
Le tableau suivant présente quelques exemples d'appels de fonction qui provoquent une erreur de séquence de fonction :
Séquence d'appels |
|---|
|
|
|
|
|
|
|
|
Exemple
L'exemple suivant crée quatre fichiers à l'aide de différents paramètres de bcp_setbulkmode.
// compile with: sqlncli11.lib odbc32.lib
#include <windows.h>
#include <stdio.h>
#include <tchar.h>
#include <sqlext.h>
#include "sqlncli.h"
// Global variables
SQLHENV g_hEnv = NULL;
SQLHDBC g_hDbc = NULL;
void ODBCCleanUp() {
if (g_hDbc) {
SQLDisconnect(g_hDbc);
SQLFreeHandle(SQL_HANDLE_DBC, g_hDbc);
g_hDbc = NULL;
}
if (g_hEnv) {
SQLFreeHandle(SQL_HANDLE_ENV, g_hEnv);
g_hEnv = NULL;
}
}
BOOL MakeODBCConnection(TCHAR * pszServer) {
TCHAR szConnectionString[500];
TCHAR szOutConnectionString[500];
SQLSMALLINT iLen;
SQLRETURN rc;
_sntprintf_s(szConnectionString, 500, TEXT("DRIVER={SQL Server Native Client 11.0};Server=%s;Trusted_connection=yes;"), pszServer);
rc = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE,&g_hEnv);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLAllocHandle(SQL_HANDLE_ENV...) failed\n");
return false;
}
rc = SQLSetEnvAttr(g_hEnv,SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_UINTEGER);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLSetEnvAttr failed\n");
SQLFreeHandle(SQL_HANDLE_ENV, g_hEnv);
return false;
}
rc = SQLAllocHandle( SQL_HANDLE_DBC, g_hEnv , &g_hDbc);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLAllocHandle(SQL_HANDLE_DBC...) failed\n");
SQLFreeHandle(SQL_HANDLE_ENV, g_hEnv);
return false;
}
// Enable BCP
rc = SQLSetConnectAttr(g_hDbc, SQL_COPT_SS_BCP, (SQLPOINTER)SQL_BCP_ON, SQL_IS_INTEGER);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLSetConnectAttr(.. SQL_COPT_SS_BCP, (SQLPOINTER)SQL_BCP_ON ...) failed\n");
ODBCCleanUp();
return false;
}
// connecting ...
rc = SQLDriverConnect(g_hDbc,NULL, (SQLTCHAR*)szConnectionString, SQL_NTS, (SQLTCHAR*)szOutConnectionString, 500, &iLen, SQL_DRIVER_NOPROMPT);
if (SQL_SUCCESS != rc && SQL_SUCCESS_WITH_INFO != rc) {
printf("SQLDriverConnect(SQL_HANDLE_DBC...) failed\n");
ODBCCleanUp();
return false;
}
return true;
}
BOOL BCPSetBulkMode(TCHAR * pszServer, TCHAR * pszQureryOut, char BCPType, TCHAR * pszDataFile) {
SQLRETURN rc;
if (!MakeODBCConnection(pszServer))
return false;
rc = bcp_init(g_hDbc, NULL, pszDataFile, NULL, DB_OUT); // bcp init for queryout
if (SUCCEED != rc) {
printf("bcp_init failed\n");
ODBCCleanUp();
return false;
}
// setbulkmode
char ColTerm[] = "\t";
char RowTerm[] = "\r\n";
wchar_t wColTerm[] = L"\t";
wchar_t wRowTerm[] = L"\r\n";
BYTE * pColTerm = NULL;
int cbColTerm = NULL;
BYTE * pRowTerm = 0;
int cbRowTerm = 0;
int bulkmode = -1;
if (BCPType == 'c') { // bcp -c
pColTerm = (BYTE*)ColTerm;
pRowTerm = (BYTE*)RowTerm;
cbColTerm = 1;
cbRowTerm = 2;
bulkmode = BCP_OUT_CHARACTER_MODE;
}
else
if (BCPType == 'w') { // bcp -w
pColTerm = (BYTE*)wColTerm;
pRowTerm = (BYTE*)wRowTerm;
cbColTerm = 2;
cbRowTerm = 4;
bulkmode = BCP_OUT_WIDE_CHARACTER_MODE;
}
else
if (BCPType == 'n') // bcp -n
bulkmode = BCP_OUT_NATIVE_MODE;
else
if (BCPType == 'N') // bcp -n
bulkmode = BCP_OUT_NATIVE_TEXT_MODE;
else {
printf("unknown bcp mode\n");
ODBCCleanUp();
return false;
}
rc = bcp_setbulkmode(g_hDbc, bulkmode, pColTerm, cbColTerm, pRowTerm, cbRowTerm);
if (SUCCEED != rc) {
printf("bcp_setbulkmode failed\n");
ODBCCleanUp();
return false;
}
// set queryout TSQL statement
rc = bcp_control(g_hDbc, BCPHINTS , pszQureryOut);
if (SUCCEED != rc) {
printf("bcp_control(..BCP_OPTION_HINTS..) failed\n");
ODBCCleanUp();
return false;
}
// bcp copy
DBINT nRowsInserted = 0;
rc = bcp_exec(g_hDbc, &nRowsInserted);
if (SUCCEED != rc) {
printf("bcp_exec failed\n");
ODBCCleanUp();
return false;
}
printf("bcp done\n");
ODBCCleanUp();
return true;
}
int main() {
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -c test', 1,2") , 'c', TEXT("bcpc.dat"));
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -w test', 1,2") , 'w', TEXT("bcpw.dat"));
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -c test', 1,2") , 'n', TEXT("bcpn.dat"));
BCPSetBulkMode(TEXT("localhost"), TEXT("SELECT 'this is a bcp -w test', 1,2") , 'N', TEXT("bcp_N.dat"));
}