1 files changed, 6 insertions, 0 deletions
diff --git a/libmysqlpp/my-connection.cpp b/libmysqlpp/my-connection.cpp
index 6e4d1a1..30cef18 100644
--- a/libmysqlpp/my-connection.cpp
+++ b/libmysqlpp/my-connection.cpp
@@ -210,6 +210,9 @@ MySQL::Connection::beginBulkUpload(const char * table, const char * extra)
 void
 MySQL::Connection::endBulkUpload(const char * msg)
 {
+	if (!ctx) {
+		throw std::logic_error("No bulk upload in progress");
+	}
 	ctx->loadBuf = nullptr;
 	ctx->loadBufLen = 0;
 	ctx->bufOff = msg ? -1 : 0;
@@ -228,6 +231,9 @@ MySQL::Connection::endBulkUpload(const char * msg)
 size_t
 MySQL::Connection::bulkUploadData(const char * data, size_t len) const
 {
+	if (!ctx) {
+		throw std::logic_error("No bulk upload in progress");
+	}
 	ctx->loadBuf = data;
 	ctx->loadBufLen = len;
 	ctx->bufOff = 0;